面試突擊:線程池有哪些狀態?狀態是如何轉換的?
作者 | 磊哥
來源 | Java面試真題解析(ID:aimianshi666)
轉載請聯系授權(微信ID:GG_Stone)
在 Java 中,線程池的狀態和線程的狀態是完全不同的,線程有 6 種狀態:NEW:初始化狀態、RUNNABLE:可運行/運行狀態、BLOCKED:阻塞狀態、WAITING:無時限等待狀態、TIMED_WAITING:有時限等待狀態和 TERMINATED:終止狀態。而線程池的狀態有以下 5 種:
- RUNNING:運行狀態,線程池創建好之后就會進入此狀態,如果不手動調用關閉方法,那么線程池在整個程序運行期間都是此狀態。
- SHUTDOWN:關閉狀態,不再接受新任務提交,但是會將已保存在任務隊列中的任務處理完。
- STOP:停止狀態,不再接受新任務提交,并且會中斷當前正在執行的任務、放棄任務隊列中已有的任務。
- TIDYING:整理狀態,所有的任務都執行完畢后(也包括任務隊列中的任務執行完),當前線程池中的活動線程數降為 0 時的狀態。到此狀態之后,會調用線程池的 terminated() 方法。
- TERMINATED:銷毀狀態,當執行完線程池的 terminated() 方法之后就會變為此狀態。
這 5 種狀態可以在 ThreadPoolExecutor 源碼中找到,如下圖所示:
線程池狀態轉移
線程池的狀態轉移有兩條路徑:
- 當調用 shutdown() 方法時,線程池的狀態會從 RUNNING 到 SHUTDOWN,再到 TIDYING,最后到 TERMENATED 銷毀狀態。
- 當調用 shutdownNow() 方法時,線程池的狀態會從 RUNNING 到 STOP,再到 TIDYING,最后到 TERMENATED 銷毀狀態。
線程狀態轉換的流程如下圖所示:
terminated方法
線程池中的 terminated() 方法,也就是線程池從 TIDYING 轉換到 TERMINATED 狀態時調用的方法,默認是空的,它的源碼如下:
我們可以在創建線程池的時候重寫 terminated() 方法,具體實現代碼如下:
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class ThreadPoolStateTransition {
public static void main(String[] args) throws InterruptedException {
// 創建線程池
ThreadPoolExecutor threadPool = new ThreadPoolExecutor(10, 10, 0L,
TimeUnit.SECONDS, new LinkedBlockingQueue<>(100)) {
@Override
protected void terminated() {
super.terminated();
System.out.println("執行 terminated() 方法");
}
};
// 關閉線程池
threadPool.shutdown();
// 等待線程池執行完再退出
while (!threadPool.awaitTermination(1, TimeUnit.SECONDS)) {
System.out.println("線程池正在運行中");
}
}
}
總結
線程池的狀態總共有 5 種:RUNNING:運行狀態、SHUTDOWN:關閉狀態、STOP:停止狀態、TIDYING:整理狀態和 TERMINATED:銷毀狀態。默認情況下,如果不調用關閉方法,線程池會一直處于 RUNNING 狀態,而線程池狀態的轉移有兩個路徑:當調用 shutdown() 方法時,線程池的狀態會從 RUNNING 到 SHUTDOWN,再到 TIDYING,最后到 TERMENATED 銷毀狀態;當調用 shutdownNow() 方法時,線程池的狀態會從 RUNNING 到 STOP,再到 TIDYING,最后到 TERMENATED 銷毀狀態。