JAVA shutdown和shutdownNow的區別

    shutDown() 

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

            shutdownNow() 

     根據JDK文檔描述，大致意思是：執行該方法，線程池的狀態立刻變成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();”即可。 
      還是那句話，希望對需要了解的人有點幫助。 

 

 

轉自：http://www.iteye.com/topic/649677