1.導(dǎo)語

最近在工作中，有遇到下面這樣一段代碼，某個同事一看到代碼中的shutdown()，馬上就斷定這代碼執(zhí)行不了，我問為什么這么說，他說線程池都關(guān)了，這任務(wù)怎么執(zhí)行？不能說沒有問題，但事實真如他所說嗎，我們來探一探shutdown()的虛實。

簡單代碼

2.shutdown 源碼

shutdown 源碼

從shutdown 源碼的注釋我們可以看到，它會初始化一個順序的已提交的任務(wù)的關(guān)閉操作，并且不再接受新的任務(wù)；如果線程池已經(jīng)被showdown了，那么該方法的調(diào)用將沒有任何的效果了。

下面我來對showdown內(nèi)部調(diào)用的方法做個解析。

checkShutdownAccess

checkShutdownAccess

這個方法其實沒什么說的，比較簡單，就是對workers的線程做一個安全權(quán)限檢查。

advanceRunState

advanceRunState

該方法通過cas操作設(shè)置runState。如果當(dāng)前的線程池的狀態(tài)值大于給定的值，，也即是runStateAtLeast(c, targetState) 返回true ，那么就不做任何操作了，直接break；如果返回false，那么就看ctl.compareAndSet(c, ctlOf(targetState, workerCountOf(c))) 設(shè)置是否成功，否則一直重復(fù)這個過程。

interruptIdleWorkers

interruptIdleWorkers

里面有一個interruptIdleWorkers 方法，默認傳了false。傳false的意思是把，在獲取鎖的情況下，把workers的線程都執(zhí)行interrupt()操作。

interruptIdleWorkers

interruptIdleWorkers

注釋說明，中斷可能正在等待任務(wù)的線程(表示沒有被鎖定)以便他們可以檢查終止或配置更改。忽略SecurityExceptions(在這種情況下，某些線程可能會保留不間斷)。

如果線程沒有被interrupt 并且tryLock到鎖了，那么就可以判定這是一個IdleWorkers，將會執(zhí)行interrupt() 方法。如果worker線程在執(zhí)行任務(wù)，runWorker方法中中執(zhí)行的Worker是占有鎖的，這里也就無法獲取到鎖，即tryLock不到，就是非IdleWorkers。

tryTerminate

tryTerminate

先看注釋，如果線程池狀態(tài)是shutdown并且線程池和隊列是空的，或者線程池是stop狀態(tài)并且線程池是空的，把他改為terminate狀態(tài)；如果線程池可以被terminate，但是workerCount 不為0，終止一個dle worker來確保 shutdown 信號傳遞下去。該方法一定要跟在任何可能會使terminate的操作之后----減少worker count 或在showdow中從隊列中移除任務(wù)。

if (isRunning(c) || runStateAtLeast(c, TIDYING) || (runStateOf(c) == SHUTDOWN && ! workQueue.isEmpty())) return;//如果線程池的狀態(tài)是isRunning，或者狀態(tài)值>=TIDYING,或者SHUTDOWN并且workQueue不為//空，直接返回if (workerCountOf(c) != 0) { // Eligible to terminate interruptIdleWorkers(ONLY_ONE); return; }//如果workerCountOf 不為0，表示可以被terminate，interruptIdleWorkers(true) 線程后將 //shutdown 信號傳遞下去。if (ctl.compareAndSet(c, ctlOf(TIDYING, 0))) { try { terminated(); } finally { ctl.set(ctlOf(TERMINATED, 0)); termination.signalAll(); } return;}//這里通過cas 將狀態(tài)設(shè)置為TIDYING，如果成功則調(diào)用 terminated()方法，執(zhí)行成功后，最后 將狀態(tài)//設(shè)置為TERMINATED，并喚醒awaitTermination中等待的線程。

實例

ThreadPoolExecutor poolExecutor = new ThreadPoolExecutor(5, 10, 30, TimeUnit.SECONDS, new ArrayBlockingQueue<>(5)); for (int i = 0; i < 5; i++) { poolExecutor.submit(new MyTask()); } poolExecutor.shutdown();try { //5秒后關(guān)閉 poolExecutor.awaitTermination(5, TimeUnit.SECONDS); } catch (InterruptedException e) { System.out.println(e.getMessage()); }*/class MyTask implements Runnable { @Override public void run() { try { System.out.println(Thread.currentThread().getName()); Thread.sleep(3000); }catch (Exception e) { System.out.println(e.getMessage()); } }}

小結(jié)

通過以上的一些分析，當(dāng)然不夠全面，還有一些方法沒有說明，以及一個demo，我們可以看到線程池關(guān)閉都能正確輸出結(jié)果。線程池關(guān)閉的關(guān)鍵就在于一個worker退出后會調(diào)用tryTerminate()，將這種信號傳遞下去，其他的線程才能被依次處理，最終塵歸塵，變?yōu)?Terminate。

好了，喜歡的朋友點贊+關(guān)注+轉(zhuǎn)發(fā)，與小編共同成長[奮斗][奮斗][奮斗]

與50位技術(shù)專家面對面20年技術(shù)見證，附贈技術(shù)全景圖

總結(jié)

以上是生活随笔為你收集整理的线程池什么时候调用shutdown方法_ThreadPoolExecutor.shutdown()？的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。