本文主要參考：《think in java》
好，下面上貨。
正常情況下，如果不做特殊的處理，在主線程中是不能夠捕獲到子線程中的異常的。
例如下面的情況。
-
package com.xueyou.demo.theadexceptiondemo;
-
-
public
class ThreadExceptionRunner implements Runnable{
-
@Override
-
public void run() {
-
throw
new RuntimeException(
"error !!!!");
-
}
-
}
使用線程執行上面的任務
-
package com.xueyou.demo.theadexceptiondemo;
-
-
import com.sun.glass.ui.TouchInputSupport;
-
-
import java.util.concurrent.ExecutorService;
-
import java.util.concurrent.Executors;
-
import java.util.concurrent.ThreadFactory;
-
-
public
class ThreadExceptionDemo {
-
public static void main(String[] args) {
-
try {
-
Thread thread =
new Thread(
new ThreadExceptionRunner());
-
thread.start();
-
}
catch (Exception e) {
-
System.out.println(
"========");
-
e.printStackTrace();
-
}
finally {
-
}
-
System.out.println(
123);
-
}
-
}
執行結果如下：
如果想要在主線程中捕獲子線程的異常，我們需要使用ExecutorService，同時做一些修改。
如下：
-
package com.xueyou.demo.theadexceptiondemo;
-
-
import com.sun.glass.ui.TouchInputSupport;
-
-
import java.util.concurrent.ExecutorService;
-
import java.util.concurrent.Executors;
-
import java.util.concurrent.ThreadFactory;
-
-
public
class ThreadExceptionDemo {
-
public static void main(String[] args) {
-
try {
-
Thread thread =
new Thread(
new ThreadExceptionRunner());
-
thread.start();
-
}
catch (Exception e) {
-
System.out.println(
"========");
-
e.printStackTrace();
-
}
finally {
-
}
-
System.out.println(
123);
-
ExecutorService exec = Executors.newCachedThreadPool(
new HandleThreadFactory());
-
exec.execute(
new ThreadExceptionRunner());
-
exec.shutdown();
-
}
-
}
-
-
class MyUncaughtExceptionHandle implements Thread.UncaughtExceptionHandler {
-
@Override
-
public void uncaughtException(Thread t, Throwable e) {
-
System.out.println(
"caught " + e);
-
}
-
}
-
-
class HandleThreadFactory implements ThreadFactory {
-
@Override
-
public Thread newThread(Runnable r) {
-
System.out.println(
"create thread t");
-
Thread t =
new Thread(r);
-
System.out.println(
"set uncaughtException for t");
-
t.setUncaughtExceptionHandler(
new MyUncaughtExceptionHandle());
-
return t;
-
}
-
-
}
這樣就能夠捕獲到異常了，運行結果如下：
上面的方式是設置每一個線程執行時候的異常處理。如果每一個線程的異常處理相同，我們可以用如下的方式進行處理，使用Thread的靜態方法。
Thread.setDefaultUncaughtExceptionHandler(new MyUncaughtExceptionHandle());
整體代碼如下：
-
package com.xueyou.demo.theadexceptiondemo;
-
-
import com.sun.glass.ui.TouchInputSupport;
-
-
import java.util.concurrent.ExecutorService;
-
import java.util.concurrent.Executors;
-
import java.util.concurrent.ThreadFactory;
-
-
/**
-
* Created by wuxueyou on
2018/
6/
24.
-
*/
-
public
class ThreadExceptionDemo {
-
public static void main(String[] args) {
-
try {
-
Thread thread = new Thread(new ThreadExceptionRunner());
-
thread.start();
-
} catch (Exception e) {
-
System.out.println("========");
-
e.printStackTrace();
-
} finally {
-
}
-
System.out.println(123);
-
Thread.setDefaultUncaughtExceptionHandler(new MyUncaughtExceptionHandle());
-
// ExecutorService exec = Executors.newCachedThreadPool(new HandleThreadFactory());
-
ExecutorService exec = Executors.newCachedThreadPool();
-
exec.execute(new ThreadExceptionRunner());
-
exec.shutdown();
-
-
}
-
}
-
運行結果：
