一、一個線程池中的線程異常了，那么線程池會怎么處理這個線程?

需要說明，本文的線程池都是java.util.concurrent.ExecutorService線程池，本文將圍繞驗證，閱讀源碼倆方面來解析這個問題。ZYn28資訊網——每日最新資訊28at.com

二、代碼驗證

2.1 驗證execute提交線程池中

2.1.1 測試代碼：

public class ThreadPoolExecutorDeadTest {    public static void main(String[] args) throws InterruptedException {        ExecutorService executorService = buildThreadPoolExecutor();        executorService.execute(() -> exeTask("execute"));        executorService.execute(() -> exeTask("execute"));        executorService.execute(() -> exeTask("execute-exception"));        executorService.execute(() -> exeTask("execute"));        executorService.execute(() -> exeTask("execute"));        Thread.sleep(5000);        System.out.println("再次執行任務=======================");        executorService.execute(() -> exeTask("execute"));        executorService.execute(() -> exeTask("execute"));        executorService.execute(() -> exeTask("execute"));        executorService.execute(() -> exeTask("execute"));        executorService.execute(() -> exeTask("execute"));    }    public static ExecutorService buildThreadPoolExecutor() {        return new ThreadPoolExecutor(5, 10, 30, TimeUnit.SECONDS,                new LinkedBlockingQueue<>(1000), new ThreadFactoryBuilder().setNameFormat("test-%s").build()                , new ThreadPoolExecutor.CallerRunsPolicy());    }    private static void exeTask(String name) {        String printStr = "[thread-name:" + Thread.currentThread().getName() + ",執行方式:" + name + "]";        if ("execute-exception".equals(name)) {            throw new RuntimeException(printStr + ", 我拋異常了");        } else {            System.out.println(printStr);        }    }}

2.1.2 執行結果如下：

ZYn28資訊網——每日最新資訊28at.com

ZYn28資訊網——每日最新資訊28at.com

2.1.3 結論：

2.2 驗證submit提交線程池中

2.2.1 測試代碼：

public class ThreadPoolExecutorDeadTest {    public static void main(String[] args) throws InterruptedException {        ExecutorService executorService = buildThreadPoolExecutor();        executorService.submit(() -> exeTask("execute"));        executorService.submit(() -> exeTask("execute"));        executorService.submit(() -> exeTask("execute-exception"));        executorService.submit(() -> exeTask("execute"));        executorService.submit(() -> exeTask("execute"));        Thread.sleep(5000);        System.out.println("再次執行任務=======================");        executorService.submit(() -> exeTask("execute"));        executorService.submit(() -> exeTask("execute"));        executorService.submit(() -> exeTask("execute"));        executorService.submit(() -> exeTask("execute"));        executorService.submit(() -> exeTask("execute"));    }    public static ExecutorService buildThreadPoolExecutor() {        return new ThreadPoolExecutor(5, 10, 30, TimeUnit.SECONDS,                new LinkedBlockingQueue<>(1000), new ThreadFactoryBuilder().setNameFormat("test-%s").build()                , new ThreadPoolExecutor.CallerRunsPolicy());    }    private static void exeTask(String name) {        String printStr = "[thread-name:" + Thread.currentThread().getName() + ",執行方式:" + name + "]";        if ("execute-exception".equals(name)) {            throw new RuntimeException(printStr + ", 我拋異常了");        } else {            System.out.println(printStr);        }    }}

2.2.2 執行結果如下：

ZYn28資訊網——每日最新資訊28at.com

ZYn28資訊網——每日最新資訊28at.com

2.2.3 結論：

submit 提交到線程池的方式，如果執行中拋出異常，并且沒有catch，不會拋出異常，不會創建新的線程。ZYn28資訊網——每日最新資訊28at.com

三、源碼解析

3.1java.util.concurrent.AbstractExecutorService#submit(java.lang.Runnable)

ZYn28資訊網——每日最新資訊28at.com

ZYn28資訊網——每日最新資訊28at.com

3.2 查看execute方法的執行邏輯java.util.concurrent.ThreadPoolExecutor#runWorker

ZYn28資訊網——每日最新資訊28at.com

ZYn28資訊網——每日最新資訊28at.com

3.3 java.util.concurrent.ThreadPoolExecutor#processWorkerExit

ZYn28資訊網——每日最新資訊28at.com

ZYn28資訊網——每日最新資訊28at.com

3.4 為什么submit方法，沒有創建新的線程，而是繼續復用原線程？

還記得，我們在3.1的時候，發現submit也是調用了execute方法，但是在調用之前,包裝了一層 RunnableFuture，那一定是在RunnableFuture的實現 FutureTask中有特殊處理了，我們查看源碼可以發現。ZYn28資訊網——每日最新資訊28at.com

ZYn28資訊網——每日最新資訊28at.com

ZYn28資訊網——每日最新資訊28at.com

ZYn28資訊網——每日最新資訊28at.com

ZYn28資訊網——每日最新資訊28at.com

但是，我們通過java.util.concurrent.FutureTask#get()，就可以獲取對應的異常信息。ZYn28資訊網——每日最新資訊28at.com

四、總結

?當執行方式是execute時,可以看到堆棧異常的輸出，線程池會把這個線程移除掉，并創建一個新的線程放到線程池中。ZYn28資訊網——每日最新資訊28at.com

?當執行方式是submit時,堆棧異常沒有輸出。但是調用Future.get()方法時，可以捕獲到異常，不會把這個線程移除掉，也不會創建新的線程放入到線程池中。ZYn28資訊網——每日最新資訊28at.com

以上倆種執行方式，都不會影響線程池里面其他線程的正常執行。ZYn28資訊網——每日最新資訊28at.com

本文鏈接：http://www.www897cc.com/showinfo-26-80828-0.html"線程池中線程異常后：銷毀還是復用？"

聲明：本網頁內容旨在傳播知識，若有侵權等問題請及時與本網聯系，我們將在第一時間刪除處理。郵件：2376512515@qq.com

上一篇： 探索Golang的優雅爬蟲框架 Colly

下一篇： .NET WebAPI 自定義返回類：實現統一與靈活的API響應