//Thread類中的接口
public interface UncaughtExceptionHanlder {
?? ?void uncaughtException(Thread t, Throwable e);
}

public class MyUnchecckedExceptionhandler implements UncaughtExceptionHandler {
? ? @Override
? ? public void uncaughtException(Thread t, Throwable e) {
? ? ? ? System.out.println("捕獲異常處理方法：" + e);
? ? }
}

Thread t = new Thread(new ExceptionThread());
t.setUncaughtExceptionHandler(new MyUnchecckedExceptionhandler());
t.start();

ExecutorService exec = Executors.newCachedThreadPool(new ThreadFactory(){
? ? ? ? ? ? @Override
? ? ? ? ? ? public Thread newThread(Runnable r) {
? ? ? ? ? ? ? ? Thread thread = new Thread(r);
? ? ? ? ? ? ? ? thread.setUncaughtExceptionHandler(new MyUnchecckedExceptionhandler());
? ? ? ? ? ? ? ? return thread;
? ? ? ? ? ? }
});
exec.execute(new ExceptionThread());

public V get() throws InterruptedException, ExecutionException {
? ? int s = state;
? ? if (s <= COMPLETING)//如果任務(wù)沒有結(jié)束，則等待結(jié)束
? ? ? ? s = awaitDone(false, 0L);
? ? return report(s);//如果執(zhí)行結(jié)束，則報(bào)告執(zhí)行結(jié)果
}

@SuppressWarnings("unchecked")
private V report(int s) throws ExecutionException {
? ? Object x = outcome;
? ? if (s == NORMAL)//如果執(zhí)行正常，則返回結(jié)果
? ? ? ? return (V)x;
? ? if (s >= CANCELLED)//如果任務(wù)被取消，調(diào)用get則報(bào)CancellationException
? ? ? ? throw new CancellationException();
? ? throw new ExecutionException((Throwable)x);//執(zhí)行異常，則拋出ExecutionException
}

//1.創(chuàng)建線程組
ThreadGroup threadGroup =
? ? ? ? // 這是匿名類寫法
? ? ? ? new ThreadGroup("group") {
? ? ? ? ? ? // 繼承ThreadGroup并重新定義以下方法
? ? ? ? ? ? // 在線程成員拋出unchecked exception 會(huì)執(zhí)行此方法
? ? ? ? ? ? @Override
? ? ? ? ? ? public void uncaughtException(Thread t, Throwable e) {
? ? ? ? ? ? ? ? //4.處理捕獲的線程異常
? ? ? ? ? ? }
? ? ? ? };
//2.創(chuàng)建Thread ? ? ? ?
Thread thread = new Thread(threadGroup, new Runnable() {
? ? @Override
? ? public void run() {
? ? ? ? System.out.println(1 / 0);

? ? }
}, "my_thread"); ?
//3.啟動(dòng)線程
thread.start(); ??

// 設(shè)置默認(rèn)的線程異常捕獲處理器
Thread.setDefaultUncaughtExceptionHandler(new MyUnchecckedExceptionhandler());

//1.創(chuàng)建FeatureTask
FutureTask<Integer> futureTask = new FutureTask<>(new Callable<Integer>() {
? ? @Override
? ? public Integer call() throws Exception {
? ? ? ? return 1/0;
? ? }
});
//2.創(chuàng)建Thread
Thread thread = new Thread(futureTask);
//3.啟動(dòng)線程
thread.start();
try {
? ? Integer result = futureTask.get();
} catch (InterruptedException e) {
? ? e.printStackTrace();
} catch (ExecutionException e) {
? ? //4.處理捕獲的線程異常
}

//1.創(chuàng)建線程池
ExecutorService executorService = Executors.newFixedThreadPool(10);
//2.創(chuàng)建Callable，有返回值的，你也可以創(chuàng)建一個(gè)線程實(shí)現(xiàn)Callable接口。
// ?如果你不需要返回值，這里也可以創(chuàng)建一個(gè)Thread即可，在第3步時(shí)submit這個(gè)thread。
Callable<Integer> callable = new Callable<Integer>() {
? ? @Override
? ? public Integer call() throws Exception {
? ? ? ? return 1/0;
? ? }
};
//3.提交待執(zhí)行的線程
Future<Integer> future = executorService.submit(callable);
try {
? ? ?Integer result = future.get();
} catch (InterruptedException e) {
? ? e.printStackTrace();
} catch (ExecutionException e) {
? ? //4.處理捕獲的線程異常
}

//1.創(chuàng)建線程池
ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(10, 10, 0L, TimeUnit.MILLISECONDS,
? ? ? ? new LinkedBlockingQueue<>()) {
? ? @Override
? ? protected void afterExecute(Runnable r, Throwable t) {
? ? ? ? if (r instanceof Thread) {
? ? ? ? ? ? if (t != null) {
? ? ? ? ? ? ? ? //處理捕獲的異常
? ? ? ? ? ? }
? ? ? ? } else if (r instanceof FutureTask) {
? ? ? ? ? ? FutureTask futureTask = (FutureTask) r;
? ? ? ? ? ? try {
? ? ? ? ? ? ? ? futureTask.get();
? ? ? ? ? ? } catch (InterruptedException e) {
? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? } catch (ExecutionException e) {
? ? ? ? ? ? ? ? //處理捕獲的異常
? ? ? ? ? ? }
? ? ? ? }

? ? }
};


Thread t1 = new Thread(() -> {
? ? int c = 1 / 0;
});
threadPoolExecutor.execute(t1);

Callable<Integer> callable = () -> 2 / 0;
threadPoolExecutor.submit(callable);