Java 線程池 深度解析：四大工廠方法、七大參數、工作隊列與優化實戰

直接 new Thread() 缺點多：資源消耗大、響應慢、無管控。線程池透過重用、管控、定時功能解決這些問題。本文系統講解 Executors 四大工廠、ThreadPoolExecutor 七大參數、BlockingQueue 策略、關閉機制、流程圖與優化建議。

一、Executors 四大工廠方法對比

共同預設：DefaultThreadFactory (命名 pool-m-thread-n)、AbortPolicy 拒絕策略。

二、ThreadPoolExecutor 七大參數詳解

public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize,
    long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue,
    ThreadFactory threadFactory, RejectedExecutionHandler handler)

1. corePoolSize：基本大小。提交任務時，線程數 < core 創建新線程 (即使有空閒)；≥ core 則看隊列。可用 prestartCoreThread() 預熱。
2. maximumPoolSize：最大大小。隊列滿且線程數 < max 時創建新線程。無界隊列可忽略此參數。
3. keepAliveTime：存活時間。線程數 > core 時，空閒超過此時間回收。allowCoreThreadTimeOut(true) 可套用至核心線程。
4. unit：時間單位 (NANOSECONDS ~ DAYS)。
5. workQueue：任務隊列。三大策略：
   • 直接提交 SynchronousQueue：不緩衝，直接交給線程，適合無界 maxPool
   • 無界隊列 LinkedBlockingQueue：core 線程忙時入隊，線程數不超過 core
   • 有界隊列 ArrayBlockingQueue：防資源耗盡，需平衡隊列大小與 maxPool
6. threadFactory：創建線程工廠，統一命名、優先級、非守護線程。
7. handler：拒絕策略 (飽和時)：
   • AbortPolicy：拋 RejectedExecutionException (預設)
   • CallerRunsPolicy：調用者執行，自然限流
   • DiscardPolicy：靜默丟棄
   • DiscardOldestPolicy：丟棄隊頭最舊任務並重試

三、常見 BlockingQueue 實現

四、線程池關閉機制

• shutdown()：狀態→SHUTDOWN，中斷無任務線程，等待任務完成
• shutdownNow()：狀態→STOP，中斷所有線程 (含執行中)，返回未執行任務列表
• 均用 interrupt()，無法響應中斷的任務可能永不結束
• isShutdown() / isTerminated() 判斷狀態

五、執行流程圖

1. 核心線程未滿？→ 創建線程執行
2. 工作隊列未滿？→ 入隊等待
3. 最大線程未滿？→ 創建線程執行
4. 否則 → 拒絕策略處理

六、優化實戰

1. 任務類型導向配置

• CPU 密集型：線程數 ≤ CPU 核心數 (避免上下文切換開銷)
• I/O 密集型：線程數 > CPU 核心數 (如 2*N)，提高 CPU 利用率
• 混合型：拆分為 CPU/I/O 子任務，若耗時差距小則拆分提升吞吐；差距大則無意義

2. 監控指標

• taskCount / completedTaskCount：總/已完成任務數
• largestPoolSize：歷史峰值線程數 (若 = maxPoolSize 曾滿載)
• getPoolSize()：當前線程數 (只增不減)
• getActiveCount()：活躍線程數

3. 擴展監控

繼承線程池重寫 beforeExecute()、afterExecute()、terminated() 實現：平均/最大/最小執行時間統計、慢任務告警、執行軌跡記錄。