線程池中shutdown()和shutdownNow()方法的區別

時間 2019-11-20

標籤線程 shutdown shutdownnow 方法區別简体版

原文原文鏈接

通常狀況下，當咱們頻繁的使用線程的時候，爲了節約資源快速響應需求，咱們都會考慮使用線程池，線程池使用完畢都會想着關閉，關閉的時候通常狀況下會用到shutdown和shutdownNow，這兩個函數都可以用來關閉線程池，那麼他們倆之間的區別是什麼呢？下面我就用一句話來講明白shutdown和shutdownNow的區別。java

1、一句話說明白shutdown和shutdownNow的區別函數

shutdown只是將線程池的狀態設置爲SHUTWDOWN狀態，正在執行的任務會繼續執行下去，沒有被執行的則中斷。源碼分析

而shutdownNow則是將線程池的狀態設置爲STOP，正在執行的任務則被中止，沒被執行任務的則返回。this

舉個工人吃包子的例子，一個廠的工人（Workers）正在吃包子（能夠理解爲任務），假如接到shutdown的命令，那麼這個廠的工人們則會把手頭上的包子給吃完，沒有拿到手裏的籠子裏面的包子則不能吃！而若是接到shutdownNow的命令之後呢，這些工人們馬上中止吃包子，會把手頭上沒吃完的包子放下，更別提籠子裏的包子了。 spa

一、shutDown()

    當線程池調用該方法時,線程池的狀態則馬上變成SHUTDOWN狀態。此時，則不能再往線程池中添加任何任務，不然將會拋出RejectedExecutionException異常。可是，此時線程池不會馬上退出，直到添加到線程池中的任務都已經處理完成，纔會退出。

二、shutdownNow()

執行該方法，線程池的狀態馬上變成STOP狀態，並試圖中止全部正在執行的線程，再也不處理還在池隊列中等待的任務，固然，它會返回那些未執行的任務。
     它試圖終止線程的方法是經過調用Thread.interrupt()方法來實現的，可是你們知道，這種方法的做用有限，若是線程中沒有sleep 、wait、Condition、定時鎖等應用, interrupt()方法是沒法中斷當前的線程的。因此，ShutdownNow()並不表明線程池就必定當即就能退出，它可能必需要等待全部正在執行的任務都執行完成了才能退出。

    上面對shutDown()以及shutDownNow()做了一個簡單的、理論上的分析。若是想知道why,則須要親自打開JDK源碼，分析分析。
      想要分析shutDown()以及shutDownNow()源碼，我建議首先要對ThreadPoolExecutor有個大概瞭解。由於關閉線程池的全部方法邏輯都在ThreadPoolExecutor中處理的。
      若是你真的想知道爲何，建議看一下我之前寫的一篇對ThreadPoolExecutor源碼分析的博文，我想這對你比較透徹的瞭解shutDown()和shutDownNow()的區別以及java 線程池原理有很大的幫助。博文URL：   http://xtu-xiaoxin.iteye.com/admin/blogs/647744

     廢話少說，要查看源碼，首先進入ThreadPoolExecutor的shutDown()方法: .net

public void shutdown() {  
     SecurityManager security = System.getSecurityManager();  
    if (security != null)  
            security.checkPermission(shutdownPerm);  
        final ReentrantLock mainLock = this.mainLock;  
        mainLock.lock();  
        try {  
            if (security != null) { // Check if caller can modify our threads  
                for (Worker w : workers)  
                    security.checkAccess(w.thread);  
            }  
            int state = runState;  
            if (state < SHUTDOWN)  
                //設置線程池狀態爲關閉狀態  
                runState = SHUTDOWN;     //----------------代碼1  
            try {  
                for (Worker w : workers) {  
                    //一個一箇中斷線程  
                    w.interruptIfIdle();  //-----------------代碼2  
                }  
            } catch (SecurityException se) { // Try to back out  
                runState = state;  
                // tryTerminate() here would be a no-op  
                throw se;  
            }  
            tryTerminate(); // Terminate now if pool and queue empty  
        } finally {  
            mainLock.unlock();  
        }  
    }

  看上面源碼，代碼1是線程池關閉的關鍵，若是線程池狀態一旦設爲SHUTDOWN，則在線程池中會出現兩種現象：
     1.你不能再往線程池中添加任何任務，不然會拋RejectedExecutionException異常(詳細請看ThreadPoolExecutor的addIfUnderCorePoolSize方法)。
     2.工做線程Worker得到池隊列中的任務時(詳細看Worker中的getTask()方法)的處理邏輯也發生了變化：若是線程池爲RUNNING狀態，而且池隊列中沒任務時，它會一直等待，直到你提交任務到池隊列中，而後取出任務，返回。可是，一旦你執行了shutDown()方法,線程池狀態爲SHUTDOWN狀態，它將再也不等待了，直接返回null。若是返回null，則工做線程沒有要執行的任務，直接退出(詳細看Worker中run()方法)。

    代碼2是針對這種狀況的：在線程池關閉前，有部分工做線程就一直在等着要處理的任務，也就是說工做線程空閒着(這種狀況我描述的很差,其實就是Worker正在執行getTask()方法中’ r = workQueue.take();’代碼段)。這時，調用interrupt()方法來中斷這些Worker線程。進入代碼2看看吧：。

線程

void interruptIfIdle() {  
            final ReentrantLock runLock = this.runLock;  
            /* 
             * 注意這個條件，擺明的就是要等Worker中runTask()方法運行完後才成立。 
             * 鎖機制 
             */  
            if (runLock.tryLock()) {  
                try {  
            /* 
             * 若是當前工做線程沒有正在運行，則中斷線程 
             * 他能中斷工做線程的緣由是getTask()方法能拋出一個 
             * InterruptedException。這時，則可終止那些正在執行 
             * workQueue.take()方法的工做線程 
             */  
            if (thread != Thread.currentThread())  
            thread.interrupt();           
                } finally {  
                    runLock.unlock();  
                }  
            }  
        }

最後進入shutDownNow()方法看看，這個更簡單了，就是設置線程池狀態爲STOP，而後依次調用工做線程的interrupt()方法，就這麼簡單，最後仍是把源碼貼出來吧：

code

public List<Runnable> shutdownNow() {  
       /* 
        * shutdownNow differs from shutdown only in that 
        * 1. runState is set to STOP, 
        * 2. all worker threads are interrupted, not just the idle ones, and 
        * 3. the queue is drained and returned. 
        */  
SecurityManager security = System.getSecurityManager();  
if (security != null)  
           security.checkPermission(shutdownPerm);  
  
       final ReentrantLock mainLock = this.mainLock;  
       mainLock.lock();  
       try {  
           if (security != null) { // Check if caller can modify our threads  
               for (Worker w : workers)  
                   security.checkAccess(w.thread);  
           }  
  
           int state = runState;  
           if (state < STOP)  
               runState = STOP;  
  
           try {  
               for (Worker w : workers) {  
                   w.interruptNow();  
               }  
           } catch (SecurityException se) { // Try to back out  
               runState = state;  
               // tryTerminate() here would be a no-op  
               throw se;  
           }  
  
           List<Runnable> tasks = drainQueue();  
           tryTerminate(); // Terminate now if pool and queue empty  
           return tasks;  
       } finally {  
           mainLock.unlock();  
       }  
   }