小米官宣：2023年上半年出貨量中國第一！
今日早間，小米電視官方微博帶來消息，稱2023年小米電視上半年出貨量達到了中國第一，同時還表示小米電視的巨屏風暴即將開始。“公布一個好消息2023年#小米電視上半年出貨量中國
一個線程池中的線程異常了，那么線程池會怎么處理這個線程?
需要說明，本文的線程池都是java.util.concurrent.ExecutorService線程池，本文將圍繞驗證，閱讀源碼倆方面來解析這個問題。
測試代碼：
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); } }}執行結果如下：
圖片
結論：
execute 提交到線程池的方式，如果執行中拋出異常，并且沒有在執行邏輯中catch，那么會拋出異常，并且移除拋出異常的線程，創建新的線程放入到線程池中。
測試代碼：
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); } }}執行結果如下：
圖片
結論：
submit 提交到線程池的方式，如果執行中拋出異常，并且沒有catch，不會拋出異常，不會創建新的線程。
1.java.util.concurrent.AbstractExecutorService#submit(java.lang.Runnable)；
圖片
2. 查看execute方法的執行邏輯；
圖片
3. java.util.concurrent.ThreadPoolExecutor#processWorkerExit；
圖片
可以發現，如果拋出異常，會移除拋出異常的線程，創建新的線程。
4. 為什么submit方法，沒有創建新的線程，而是繼續復用原線程；
還記得，我們在3.1的時候，發現submit也是調用了execute方法，但是在調用之前,包裝了一層 RunnableFuture，那一定是在RunnableFuture的實現 FutureTask中有特殊處理了，我們查看源碼可以發現。
圖片
圖片
圖片
圖片
但是，我們通過java.util.concurrent.FutureTask#get()就可以獲取對應的異常信息。
當一個線程池里面的線程異常后:
以上倆種執行方式，都不會影響線程池里面其他線程的正常執行。
本文鏈接：http://m.www897cc.com/showinfo-26-93697-0.htmlJava線程池中線程異常后：是銷毀還是復用
聲明：本網頁內容旨在傳播知識，若有侵權等問題請及時與本網聯系，我們將在第一時間刪除處理。郵件：2376512515@qq.com
上一篇： 大廠面試必備：如何輕松實現分布式Session管理？
下一篇： Go必知必會：數組和切片詳解
Copyright ? 2016-2023 天津谷騏科技有限公司 版權所有 sitemap.xml
違法及侵權請聯系：2376512515@qq.com 津ICP備18001702號
津公網安備 12010102000574號