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

一般情況下，當我們頻繁的使用線程的時候，為了節約資源快速響應需求，我們都會考慮使用線程池，線程池使用完畢都會想着關閉，關閉的時候一般情況下會用到shutdown和shutdownNow，這兩個函數都能夠用來關閉線程池，那么他們倆之間的區別是什么呢？下面我就用一句話來說明白shutdown和shutdownNow的區別。

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

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

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

        舉個工人吃包子的例子，一個廠的工人（Workers）正在吃包子（可以理解為任務），假如接到shutdown的命令，那么這個廠的工人們則會把手頭上的包子給吃完，沒有拿到手里的籠子里面的包子則不能吃！而如果接到shutdownNow的命令以后呢，這些工人們立刻停止吃包子，會把手頭上沒吃完的包子放下，更別提籠子里的包子了。 

   1、shutDown() 

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

   2、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()方法: 

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()方法，就這么簡單，最后還是把源碼貼出來吧： 
    
     

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();  
       }  
   }  

 

   上面代碼沒什么好分析的了，一看就明白，其實別看上面代碼一大篇，我們只關心“w.interruptNow();”即可。  

 

參考： shutdown和shutdownNow的區別

參考：  一句話說明白Java線程池中shutdown和shutdownNow的區別