Java ExcutorService優(yōu)雅關(guān)閉方式解析
關(guān)閉時可使用如下代碼
public static void waitUntilTerminate(final ExecutorService executorService, final int timeout) { try { executorService.shutdown(); if (!executorService.awaitTermination(timeout, TimeUnit.SECONDS)) { //超時后直接關(guān)閉executorService.shutdownNow(); } } catch (InterruptedException e) { //awaitTermination 出現(xiàn)中斷異常也將觸發(fā)關(guān)閉 executorService.shutdownNow(); } }
但是實際使用中,可能會出現(xiàn)即使使用了shutdownNow方法,還是無法終止線程的問題,那是因為你的線程無法被中斷
shutdownNow方法簡單理解就是給在運行的線程發(fā)一個中斷信號,如果你的線程忽略這個信號,那就無法停下來
舉個例子來說明這個問題
public class ShutDownUtilsTest { private ExecutorService executorService; @Before public void init() { executorService = Executors.newFixedThreadPool(1); } @Test public void shutDownOKTest() { ShutDownUtils.waitUntilTerminate(executorService, 1); CommonUtils.sleep(1); //等待線程處理中斷 Assert.assertTrue(executorService.isTerminated()); } @Test public void shutDownNowFailTest() { executorService.execute(this::canNotStopThread); ShutDownUtils.waitUntilTerminate(executorService, 0); CommonUtils.sleep(1); //等待線程處理中斷 Assert.assertFalse(executorService.isTerminated()); } @Test public void shutDownNowOKTest() { executorService.execute(this::stopThread); ShutDownUtils.waitUntilTerminate(executorService, 0); CommonUtils.sleep(1); //等待線程處理中斷 Assert.assertTrue(executorService.isTerminated()); } private void canNotStopThread() { for (long i = 0; i < Long.MAX_VALUE; i++) { } } private void stopThread() { for (long i = 0; i < Long.MAX_VALUE && !Thread.currentThread().isInterrupted(); i++) { } }}
從上面的測試用例可以看到canNotStopThread無法被shutDownNow終止
然而stopThread可以被正常終止,因為通過Thread.currentThread().isInterrupted()在判斷線程是否收到了中斷信號
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持好吧啦網(wǎng)。
相關(guān)文章:
1. Java8內(nèi)存模型PermGen Metaspace實例解析2. python如何實現(xiàn)word批量轉(zhuǎn)HTML3. python excel和yaml文件的讀取封裝4. python3實現(xiàn)往mysql中插入datetime類型的數(shù)據(jù)5. python爬蟲實戰(zhàn)之制作屬于自己的一個IP代理模塊6. moment轉(zhuǎn)化時間戳出現(xiàn)Invalid Date的問題及解決7. 關(guān)于 Android WebView 的內(nèi)存泄露問題8. Docker鏡像管理常用操作代碼示例9. Python中內(nèi)建模塊collections如何使用10. 詳解docker pull 下來的鏡像都存到了哪里
