淺談Java關(guān)閉線程池shutdown和shutdownNow的區(qū)別
前言
本章分為兩個(gè)議題
- 如何正確關(guān)閉線程池
- shutdown 和 shutdownNow 的區(qū)別
項(xiàng)目環(huán)境
- jdk 1.8
- github 地址:https://github.com/huajiexiewenfeng/java-concurrent
- 本章模塊:threadpool
1.線程池示例
public class ShutDownThreadPoolDemo { private ExecutorService service = Executors.newFixedThreadPool(10); public static void main(String[] args) { new ShutDownThreadPoolDemo().executeTask(); } public void executeTask() { for (int i = 0; i < 100; i++) { service.submit(() -> { System.out.println(Thread.currentThread().getName() + "->執(zhí)行"); }); } } }
執(zhí)行結(jié)果
pool-1-thread-2->執(zhí)行
pool-1-thread-3->執(zhí)行
pool-1-thread-1->執(zhí)行
pool-1-thread-4->執(zhí)行
pool-1-thread-5->執(zhí)行
pool-1-thread-6->執(zhí)行
...
執(zhí)行完成之后,主線程會(huì)一直阻塞,那么如何關(guān)閉線程池呢?本章介紹 5 種在 ThreadPoolExecutor 中涉及關(guān)閉線程池的方法,如下所示
- void shutdown
- boolean isShutdown
- boolean isTerminated
- boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException
- List<Runnable> shutdownNow
2.shutdown
第一種方法叫作 shutdown(),它可以安全地關(guān)閉一個(gè)線程池,調(diào)用 shutdown() 方法之后線程池并不是立刻就被關(guān)閉,因?yàn)檫@時(shí)線程池中可能還有很多任務(wù)正在被執(zhí)行,或是任務(wù)隊(duì)列中有大量正在等待被執(zhí)行的任務(wù),調(diào)用 shutdown() 方法后線程池會(huì)在執(zhí)行完正在執(zhí)行的任務(wù)和隊(duì)列中等待的任務(wù)后才徹底關(guān)閉。
調(diào)用 shutdown() 方法后如果還有新的任務(wù)被提交,線程池則會(huì)根據(jù)拒絕策略直接拒絕后續(xù)新提交的任務(wù)。
這段源碼位置(jdk 1.8 版本)
java.util.concurrent.ThreadPoolExecutor#execute
public void execute(Runnable command) { if (command == null) throw new NullPointerException(); int c = ctl.get(); // 線程池中的線程比核心線程數(shù)少 if (workerCountOf(c) < corePoolSize) { // 新建一個(gè)核心線程執(zhí)行任務(wù) if (addWorker(command, true)) return; c = ctl.get(); } // 核心線程已滿,但是任務(wù)隊(duì)列未滿,添加到隊(duì)列中 if (isRunning(c) && workQueue.offer(command)) { int recheck = ctl.get(); // 任務(wù)成功添加到隊(duì)列以后,再次檢查是否需要添加新的線程,因?yàn)橐汛嬖诘木€程可能被銷毀了 if (! isRunning(recheck) && remove(command)) // 如果線程池處于非運(yùn)行狀態(tài),并且把當(dāng)前的任務(wù)從任務(wù)隊(duì)列中移除成功,則拒絕該任務(wù) reject(command); else if (workerCountOf(recheck) == 0) // 如果之前的線程已經(jīng)被銷毀完,新建一個(gè)非核心線程 addWorker(null, false); } // 核心線程池已滿,隊(duì)列已滿,嘗試創(chuàng)建一個(gè)非核心新的線程 else if (!addWorker(command, false)) // 如果創(chuàng)建新線程失敗,說(shuō)明線程池關(guān)閉或者線程池滿了,拒絕任務(wù) reject(command); }
1373 行 if (! isRunning(recheck) && remove(command))
如果線程池被關(guān)閉,將當(dāng)前的任務(wù)從任務(wù)隊(duì)列中移除成功,并拒絕該任務(wù)
1378 行 else if (!addWorker(command, false))
如果創(chuàng)建新線程失敗,說(shuō)明線程池關(guān)閉或者線程池滿了,拒絕任務(wù)。
3.isShutdown
第二個(gè)方法叫作 isShutdown(),它可以返回 true 或者 false 來(lái)判斷線程池是否已經(jīng)開始了關(guān)閉工作,也就是是否執(zhí)行了 shutdown 或者 shutdownNow 方法。
這里需要注意,如果調(diào)用 isShutdown() 方法的返回的結(jié)果為 true 并不代表線程池此時(shí)已經(jīng)徹底關(guān)閉了,這僅僅代表線程池開始了關(guān)閉的流程,也就是說(shuō),此時(shí)可能線程池中依然有線程在執(zhí)行任務(wù),隊(duì)列里也可能有等待被執(zhí)行的任務(wù)。
4.isTerminated
第三種方法叫作 isTerminated(),這個(gè)方法可以檢測(cè)線程池是否真正“終結(jié)”了,這不僅代表線程池已關(guān)閉,同時(shí)代表線程池中的所有任務(wù)都已經(jīng)都執(zhí)行完畢了。
比如我們上面提到的情況,如果此時(shí)已經(jīng)調(diào)用了 shutdown 方法,但是還有任務(wù)沒(méi)有執(zhí)行完,那么此時(shí)調(diào)用 isShutdown 方法返回的是 true,而 isTerminated 方法則會(huì)返回 false。
直到所有任務(wù)都執(zhí)行完畢了,調(diào)用 isTerminated() 方法才會(huì)返回 true,這表示線程池已關(guān)閉并且線程池內(nèi)部是空的,所有剩余的任務(wù)都執(zhí)行完畢了。
5.awaitTermination
第四個(gè)方法叫作 awaitTermination(),它本身并不是用來(lái)關(guān)閉線程池的,而是主要用來(lái)判斷線程池狀態(tài)的。
比如我們給 awaitTermination 方法傳入的參數(shù)是 10 秒,那么它就會(huì)陷入 10 秒鐘的等待,直到發(fā)生以下三種情況之一:
- 等待期間(包括進(jìn)入等待狀態(tài)之前)線程池已關(guān)閉并且所有已提交的任務(wù)(包括正在執(zhí)行的和隊(duì)列中等待的)都執(zhí)行完畢,相當(dāng)于線程池已經(jīng)“終結(jié)”了,方法便會(huì)返回 true
- 等待超時(shí)時(shí)間到后,第一種線程池“終結(jié)”的情況始終未發(fā)生,方法返回 false
- 等待期間線程被中斷,方法會(huì)拋出 InterruptedException 異常
- 調(diào)用 awaitTermination 方法后當(dāng)前線程會(huì)嘗試等待一段指定的時(shí)間,如果在等待時(shí)間內(nèi),線程池已關(guān)閉并且內(nèi)部的任務(wù)都執(zhí)行完畢了,也就是說(shuō)線程池真正“終結(jié)”了,那么方法就返回 true,否則超時(shí)返回 fasle。
6.shutdownNow
最后一個(gè)方法是 shutdownNow(),它和 shutdown() 的區(qū)別就是多了一個(gè) Now,表示立刻關(guān)閉的意思,不推薦使用這一種方式關(guān)閉線程池。
在執(zhí)行 shutdownNow 方法之后,首先會(huì)給所有線程池中的線程發(fā)送 interrupt 中斷信號(hào),嘗試中斷這些任務(wù)的執(zhí)行,然后會(huì)將任務(wù)隊(duì)列中正在等待的所有任務(wù)轉(zhuǎn)移到一個(gè) List 中并返回,我們可以根據(jù)返回的任務(wù) List 來(lái)進(jìn)行一些補(bǔ)救的操作,例如記錄在案并在后期重試。
shutdownNow 源碼如下:
public List<Runnable> shutdownNow() { List<Runnable> tasks; final ReentrantLock mainLock = this.mainLock; mainLock.lock(); try { checkShutdownAccess(); advanceRunState(STOP); interruptWorkers(); tasks = drainQueue(); } finally { mainLock.unlock(); } tryTerminate(); return tasks; }
interruptWorkers
- 讓每一個(gè)已經(jīng)啟動(dòng)的線程都中斷,這樣線程就可以在執(zhí)行任務(wù)期間檢測(cè)到中斷信號(hào)并進(jìn)行相應(yīng)的處理,提前結(jié)束任務(wù)
7.shutdown 和 shutdownNow 的區(qū)別?
- shutdown 會(huì)等待線程池中的任務(wù)執(zhí)行完成之后關(guān)閉線程池,而 shutdownNow 會(huì)給所有線程發(fā)送中斷信號(hào),中斷任務(wù)執(zhí)行,然后關(guān)閉線程池
- shutdown 沒(méi)有返回值,而 shutdownNow 會(huì)返回關(guān)閉前任務(wù)隊(duì)列中未執(zhí)行的任務(wù)集合(List)
到此這篇關(guān)于淺談Java關(guān)閉線程池shutdown和shutdownNow的區(qū)別的文章就介紹到這了,更多相關(guān)Java關(guān)閉線程池shutdown和shutdownNow內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Java中讀寫鎖ReadWriteLock的原理與應(yīng)用詳解
Java并發(fā)編程提供了讀寫鎖,主要用于讀多寫少的場(chǎng)景,今天我們就重點(diǎn)來(lái)講解讀寫鎖ReadWriteLock的原理與應(yīng)用場(chǎng)景,感興趣的可以了解一下2022-09-09深入學(xué)習(xí)java位運(yùn)算的基礎(chǔ)知識(shí)
位運(yùn)算是直接對(duì)整數(shù)在內(nèi)存中的二進(jìn)制位進(jìn)行操作嗎,位運(yùn)算即可以節(jié)約內(nèi)存,同時(shí)使程序速度更快效率更高。文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,下面我們來(lái)一起學(xué)習(xí)下吧2019-06-06圖解Spring框架的設(shè)計(jì)理念與設(shè)計(jì)模式
這篇文章主要通過(guò)多圖詳細(xì)解釋Spring框架的設(shè)計(jì)理念與設(shè)計(jì)模式,需要的朋友可以參考下2015-08-08Java加密 消息摘要算法SHA實(shí)現(xiàn)詳解
這篇文章主要介紹了Java加密 消息摘要算法SHA實(shí)現(xiàn)詳解,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-07-07JWT 設(shè)置token過(guò)期時(shí)間無(wú)效的解決
這篇文章主要介紹了JWT 設(shè)置token過(guò)期時(shí)間無(wú)效的解決方案,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2022-07-07解析ConcurrentHashMap: 預(yù)熱(內(nèi)部一些小方法分析)
ConcurrentHashMap是由Segment數(shù)組結(jié)構(gòu)和HashEntry數(shù)組結(jié)構(gòu)組成。Segment的結(jié)構(gòu)和HashMap類似,是一種數(shù)組和鏈表結(jié)構(gòu),今天給大家普及java面試常見問(wèn)題---ConcurrentHashMap知識(shí),一起看看吧2021-06-06Fluent MyBatis實(shí)現(xiàn)動(dòng)態(tài)SQL
MyBatis 令人喜歡的一大特性就是動(dòng)態(tài) SQL。本文主要介紹了Fluent MyBatis實(shí)現(xiàn)動(dòng)態(tài)SQL,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2021-08-08