線程通訊的三種方法！通俗易懂
線程通信是指多個線程之間通過某種機制進行協(xié)調(diào)和交互，例如，線程等待和通知機制就是線程通訊的主要手段之一。 在 Java 中，線程等待和通知的實現(xiàn)手段有以下幾種方式：Object 類下
一個線程池中的線程異常了，那么線程池會怎么處理這個線程?
需要說明，本文的線程池都是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("再次執(zhí)行任務(wù)======================="); 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() + ",執(zhí)行方式:" + name + "]"; if ("execute-exception".equals(name)) { throw new RuntimeException(printStr + ", 我拋異常了"); } else { System.out.println(printStr); } }}執(zhí)行結(jié)果如下：
圖片
結(jié)論：
execute 提交到線程池的方式，如果執(zhí)行中拋出異常，并且沒有在執(zhí)行邏輯中catch，那么會拋出異常，并且移除拋出異常的線程，創(chuàng)建新的線程放入到線程池中。
測試代碼：
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("再次執(zhí)行任務(wù)======================="); 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() + ",執(zhí)行方式:" + name + "]"; if ("execute-exception".equals(name)) { throw new RuntimeException(printStr + ", 我拋異常了"); } else { System.out.println(printStr); } }}執(zhí)行結(jié)果如下：
圖片
結(jié)論：
submit 提交到線程池的方式，如果執(zhí)行中拋出異常，并且沒有catch，不會拋出異常，不會創(chuàng)建新的線程。
1.java.util.concurrent.AbstractExecutorService#submit(java.lang.Runnable)；
圖片
2. 查看execute方法的執(zhí)行邏輯；
圖片
3. java.util.concurrent.ThreadPoolExecutor#processWorkerExit；
圖片
可以發(fā)現(xiàn)，如果拋出異常，會移除拋出異常的線程，創(chuàng)建新的線程。
4. 為什么submit方法，沒有創(chuàng)建新的線程，而是繼續(xù)復(fù)用原線程；
還記得，我們在3.1的時候，發(fā)現(xiàn)submit也是調(diào)用了execute方法，但是在調(diào)用之前,包裝了一層 RunnableFuture，那一定是在RunnableFuture的實現(xiàn) FutureTask中有特殊處理了，我們查看源碼可以發(fā)現(xiàn)。
圖片
圖片
圖片
圖片
但是，我們通過java.util.concurrent.FutureTask#get()就可以獲取對應(yīng)的異常信息。
當一個線程池里面的線程異常后:
以上倆種執(zhí)行方式，都不會影響線程池里面其他線程的正常執(zhí)行。
本文鏈接：http://www.tebozhan.com/showinfo-26-93697-0.htmlJava線程池中線程異常后：是銷毀還是復(fù)用
聲明：本網(wǎng)頁內(nèi)容旨在傳播知識，若有侵權(quán)等問題請及時與本網(wǎng)聯(lián)系，我們將在第一時間刪除處理。郵件：2376512515@qq.com
上一篇： 大廠面試必備：如何輕松實現(xiàn)分布式Session管理？
下一篇： Go必知必會：數(shù)組和切片詳解
Copyright ? 2016-2023 天津谷騏科技有限公司 版權(quán)所有 sitemap.xml
違法及侵權(quán)請聯(lián)系：2376512515@qq.com 津ICP備18001702號
津公網(wǎng)安備 12010102000574號