J2SE 5.0 線程池核心機制深度解析：ThreadPoolExecutor 參數、隊列策略與生命週期管理

前言：從「手工管理線程」到「線程池化」的範式轉移

JDK 1.5 引入 java.util.concurrent 包，ThreadPoolExecutor 成為 Java 併發編程的基石。它不僅解決了「頻繁創建/銷毀線程開銷大」、「無限制創建線程導致 OOM」等痛點，更提供了靈活的參數配置、多樣的隊列策略、完善的生命週期鉤子，讓開發者專注於業務邏輯而非線程管控。本文深度解析線程池核心參數、工作流程、隊列交互規則與調優實戰。

一、 線程池核心架構與繼承體系

Executor (接口) → execute(Runnable)
    ↑
ExecutorService (接口) → shutdown、submit、invokeAll、awaitTermination
    ↑
ThreadPoolExecutor (核心實現類)
    ↑
ScheduledThreadPoolExecutor (定時任務擴展)

二、 七大核心構造參數詳解

public ThreadPoolExecutor(
    int corePoolSize,           // 核心線程數
    int maximumPoolSize,        // 最大線程數
    long keepAliveTime,         // 非核心線程空閒存活時間
    TimeUnit unit,              // 時間單位
    BlockingQueue workQueue, // 任務隊列
    ThreadFactory threadFactory,       // 線程工廠 (命名、守護、優先級)
    RejectedExecutionHandler handler   // 拒絕策略
)

2.1 核心參數決策指南

三、 隊列類型與線程創建/排隊決策邏輯 (核心難點)

任務提交 execute(task) 時的決策流程：

提交任務
   │
   ├─ 當前線程數 < corePoolSize
   │     → 創建新線程執行 (即使有空閒線程)
   │
   ├─ 當前線程數 ≥ corePoolSize
   │     ├─ 有空閒線程 → 空閒線程執行
   │     └─ 無空閒線程
   │           ├─ 隊列未滿 → 入隊等待
   │           └─ 隊列已滿
   │                 ├─ 當前線程數 < maximumPoolSize → 創建新線程執行
   │                 └─ 當前線程數 ≥ maximumPoolSize → 拒絕策略 handler
   │
   └─ 任務完成
         ├─ 線程數 > corePoolSize → 空閒 keepAliveTime 後回收
         └─ 線程數 ≤ corePoolSize → 永久阻塞等待新任務 (除非 allowCoreThreadTimeOut)

3.1 四大標準隊列對比

3.2 經典組合推薦

• 固定大小、有界緩衝：core=max=N, ArrayBlockingQueue(cap) — 穩定資源佔用，適合數據庫連接池、HTTP 客戶端池。
• 緊急任務優先、快速響應：core=M, max=N, SynchronousQueue — 類似 Executors.newCachedThreadPool() 但可控 max。
• 批次處理、吞吐優先：core=M, max=N, LinkedBlockingQueue — 類似 Executors.newFixedThreadPool() 但可擴展。

四、 拒絕策略 (RejectedExecutionHandler) 選型

五、 生命週期鉤子與監控擴展

5.1 受保護鉤子方法 (需繼承覆寫)

public class MonitoredThreadPool extends ThreadPoolExecutor {
    private final MetricsCollector metrics;

    public MonitoredThreadPool(...) { super(...); this.metrics = ...; }

    @Override
    protected void beforeExecute(Thread t, Runnable r) {
        super.beforeExecute(t, r);
        metrics.recordTaskStart(r);
        // 可設置 ThreadLocal 計時器、埋點 traceId
    }

    @Override
    protected void afterExecute(Runnable r, Throwable t) {
        super.afterExecute(r, t);
        metrics.recordTaskEnd(r, t);
        // 記錄耗時、異常、隊列積壓、線程池狀態
    }

    @Override
    protected void terminated() {
        super.terminated();
        metrics.reportFinalStats();
    }
}

5.2 關鍵監控指標

• getPoolSize()、getActiveCount()、getCorePoolSize()、getMaximumPoolSize()
• getQueue().size() / remainingCapacity()
• getCompletedTaskCount()、getTaskCount()
• 拒絕計數 (自定義 handler 累加)

六、 Executors 工廠方法的「隱藏坑」與替代方案

阿里巴巴開發手冊強制要求：不允許使用 Executors 創建線程池，必須手工 new ThreadPoolExecutor 明確參數。

七、 實戰調優清單

1. 任務分類：CPU 密集 vs IO 密集，分池隔離 (業務線程池、DB 線程池、HTTP 線程池)。
2. 壓測驗證：模擬尖峰流量，觀察隊列積壓、線程數變化、拒絕率、GC 頻率、CPU/內存曲線。
3. 動態調整：setCorePoolSize()、setMaximumPoolSize() 運行期調整 (配合配置中心)。
4. 優雅關閉：shutdown() → awaitTermination(timeout) → shutdownNow() 強制中斷。
5. 異常處理：任務必須 try-catch 吞噬異常或使用 Thread.setDefaultUncaughtExceptionHandler，防止線程意外死亡導致池縮容。

結語

ThreadPoolExecutor 以 7 個參數構建出極其豐富的行為空間，掌握「隊列決定線程創建、拒絕策略決定過載行為、鉤子實現可觀測性」三大核心邏輯，即可駕馭從高併發 Web 服務到大數據批次處理的各種場景。拒絕 Executors 懶人寫法，擁抱顯式配置，是併發編程成熟的標誌。