star run caller 圖片 admin state 什麽 作用 希望

參考：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()方法:

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);
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. }
20. int state = runState;
21. if (state < STOP)
22. runState = STOP;
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. }
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();”即可。
還是那句話，希望對需要了解的人有點幫助。

30W年薪的人工智能工程師只是“白菜價”？ 人工智能技術向前發展，也必然會出現一些崗位被人工智能取代，但我們相信，隨著人工智能的發展，會有更多的新的、屬於未來的工作崗位出現，是社會發展的必然產物，我們能做的也許只能是與時俱進了

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