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

??

Java代碼??

1. public ? void ?shutdown()?{??
2. ?????SecurityManager?security?=?System.getSecurityManager();??
3. ???? if ?(security?!=? null )??
4. ????????????security.checkPermission(shutdownPerm);??
5. ???????? final ?ReentrantLock?mainLock?=? this .mainLock;??
6. ????????mainLock.lock();??
7. ???????? try ?{??
8. ???????????? if ?(security?!=? null )?{? //?Check?if?caller?can?modify?our?threads ??
9. ???????????????? for ?(Worker?w?:?workers)??
10. ????????????????????security.checkAccess(w.thread);??
11. ????????????}??
12. ???????????? int ?state?=?runState;??
13. ???????????? if ?(state?<?SHUTDOWN)??
14. ???????????????? //設置線程池狀態為關閉狀態 ??
15. ????????????????runState?=?SHUTDOWN;????? //----------------代碼1 ??
16. ???????????? try ?{??
17. ???????????????? for ?(Worker?w?:?workers)?{??
18. ???????????????????? //一個一個中斷線程 ??
19. ????????????????????w.interruptIfIdle();?? //-----------------代碼2 ??
20. ????????????????}??
21. ????????????}? catch ?(SecurityException?se)?{? //?Try?to?back?out ??
22. ????????????????runState?=?state;??
23. ???????????????? //?tryTerminate()?here?would?be?a?no-op ??
24. ???????????????? throw ?se;??
25. ????????????}??
26. ????????????tryTerminate();? //?Terminate?now?if?pool?and?queue?empty ??
27. ????????}? finally ?{??
28. ????????????mainLock.unlock();??
29. ????????}??
30. ????}??

?? 看上面源碼，代碼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看看吧： 。?
???
?

Java代碼??

1. void ?interruptIfIdle()?{??
2. ???????????? final ?ReentrantLock?runLock?=? this .runLock;??
3. ???????????? /* ?
4. ?????????????*?注意這個條件，擺明的就是要等Worker中runTask()方法運行完后才成立。 ?
5. ?????????????*?鎖機制 ?
6. ?????????????*/ ??
7. ???????????? if ?(runLock.tryLock())?{??
8. ???????????????? try ?{??
9. ???????????? /* ?
10. ?????????????*?如果當前工作線程沒有正在運行，則中斷線程 ?
11. ?????????????*?他能中斷工作線程的原因是getTask()方法能拋出一個 ?
12. ?????????????*?InterruptedException。這時，則可終止那些正在執行 ?
13. ?????????????*?workQueue.take()方法的工作線程 ?
14. ?????????????*/ ??
15. ???????????? if ?(thread?!=?Thread.currentThread())??
16. ????????????thread.interrupt();???????????
17. ????????????????}? finally ?{??
18. ????????????????????runLock.unlock();??
19. ????????????????}??
20. ????????????}??
21. ????????}??

??? 最后進入shutDownNow()方法看看，這個更簡單了，就是設置線程池狀態為STOP，然后依次調用工作線程的interrupt()方法，就這么簡單，最后還是把源碼貼出來吧： ?
????
?????

Java代碼??

1. public ?List<Runnable>?shutdownNow()?{??
2. ??????? /* ?
3. ????????*?shutdownNow?differs?from?shutdown?only?in?that ?
4. ????????*?1.?runState?is?set?to?STOP, ?
5. ????????*?2.?all?worker?threads?are?interrupted,?not?just?the?idle?ones,?and ?
6. ????????*?3.?the?queue?is?drained?and?returned. ?
7. ????????*/ ??
8. SecurityManager?security?=?System.getSecurityManager();??
9. if ?(security?!=? null )??
10. ???????????security.checkPermission(shutdownPerm);??
11. ??
12. ??????? final ?ReentrantLock?mainLock?=? this .mainLock;??
13. ???????mainLock.lock();??
14. ??????? try ?{??
15. ??????????? if ?(security?!=? null )?{? //?Check?if?caller?can?modify?our?threads ??
16. ??????????????? for ?(Worker?w?:?workers)??
17. ???????????????????security.checkAccess(w.thread);??
18. ???????????}??
19. ??
20. ??????????? int ?state?=?runState;??
21. ??????????? if ?(state?<?STOP)??
22. ???????????????runState?=?STOP;??
23. ??
24. ??????????? try ?{??
25. ??????????????? for ?(Worker?w?:?workers)?{??
26. ???????????????????w.interruptNow();??
27. ???????????????}??
28. ???????????}? catch ?(SecurityException?se)?{? //?Try?to?back?out ??
29. ???????????????runState?=?state;??
30. ??????????????? //?tryTerminate()?here?would?be?a?no-op ??
31. ??????????????? throw ?se;??
32. ???????????}??
33. ??
34. ???????????List<Runnable>?tasks?=?drainQueue();??
35. ???????????tryTerminate();? //?Terminate?now?if?pool?and?queue?empty ??
36. ??????????? return ?tasks;??
37. ???????}? finally ?{??
38. ???????????mainLock.unlock();??
39. ???????}??
40. ???}??

???? 上面代碼沒什么好分析的了，一看就明白，其實別看上面代碼一大篇，我們只關心“w.interruptNow();”即可。?
????? 還是那句話，希望對需要了解的人有點幫助。?

?

?

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