深入淺出多執行緒（五）：併發包線程池設計需求與使用實戰指南

前言：線程池為何不可或缺？

執行緒建立與銷毀消耗系統資源，頻繁創建銷毀導致效能抖動。線程池透過複用執行緒、控制併發數量、管理任務佇列，顯著提升系統回應速度與穩定性，猶如資料庫連線池之於資料庫存取。JDK 1.5 java.util.concurrent 套件正式提供工業級線程池支援，本文從「設計需求」與「API 實戰」兩維度全面解析。

一、線程池核心設計需求

1. 易用性：簡單即美

• 開箱即用，無需深究實現細節
• 統一介面屏蔽複雜度

2. 可配置與可管理性

• 執行緒數量配置（核心/最大/閒置回收時間）
• 動態調整執行緒數
• 優雅關閉：停止接收新任務、完成執行中任務、中斷等待中任務
• 任務狀態監控：已提交/已完成/執行中/佇列積壓統計

3. 可擴展性

• 自訂執行緒建立策略（ThreadFactory）
• 自訂任務拒絕策略（RejectedExecutionHandler）
• 支援繼承擴展特殊調度邏輯

二、Executors 工廠方法：開箱即用的四大經典線程池

三、ThreadPoolExecutor 進階配置：滿足個性化需求

所有 Executors 方法底層均委託 ThreadPoolExecutor，直接使用構造函數可解鎖完整配置能力：

public ThreadPoolExecutor(
    int corePoolSize,           // 核心執行緒數
    int maximumPoolSize,        // 最大執行緒數
    long keepAliveTime,         // 非核心執行緒閒置存活時間
    TimeUnit unit,              // 時間單位
    BlockingQueue<Runnable> workQueue, // 任務佇列
    ThreadFactory threadFactory,       // 執行緒工廠
    RejectedExecutionHandler handler   // 拒絕策略
)

關鍵配置決策指南

1. 任務佇列選型

• ArrayBlockingQueue：有界陣列佇列，**生產環境首選**，防止 OOM
• LinkedBlockingQueue：無界鏈表佇列（Fixed/SingleThreadPool 預設），任務堆積風險高
• SynchronousQueue：零容量同步佇列（CachedThreadPool 預設），直接移交，適合高吞吐短任務
• PriorityBlockingQueue：優先級佇列，支援任務優先級調度

2. 拒絕策略選型

• AbortPolicy（預設）：拋出 RejectedExecutionException，適合關鍵業務不可丟失
• CallerRunsPolicy：呼叫者執行緒直接執行任務，**實現背壓**，適合任務不可丟失且可接受延遲
• DiscardPolicy：靜默丟棄，適合非關鍵監控、日誌類任務
• DiscardOldestPolicy：丟棄佇列最舊任務，適合即時性要求高的串流處理

3. ThreadFactory 客製化

ThreadFactory factory = new ThreadFactoryBuilder()
    .setNameFormat("order-processor-%d")
    .setDaemon(false)
    .setPriority(Thread.NORM_PRIORITY)
    .setUncaughtExceptionHandler((t, e) -> log.error("執行緒異常", e))
    .build();

四、生產環境實戰避坑指南

⚠️ CachedThreadPool OOM 風險

預設 maximumPoolSize = Integer.MAX_VALUE，大量任務湧入會瘋狂建立執行緒耗盡記憶體。**解決方案**：自訂 ThreadPoolExecutor 設定合理最大數，或使用有界佇列 + CallerRunsPolicy。

⚠️ FixedThreadPool 任務積壓導致記憶體飆升

無界 LinkedBlockingQueue 任務堆積時佔用大量堆記憶體。**解決方案**：改用 ArrayBlockingQueue 設定容量上限。

⚠️ 執行緒命名缺失導致排查困難

預設命名 pool-1-thread-1 無業務語意。**最佳實踐**：自訂 ThreadFactory 加入業務前綴。

⚠️ 異常吞沒風險

execute(Runnable) 提交任務若拋出異常不會傳播至呼叫者。**解決方案**：使用 submit(Callable) 獲取 Future，透過 future.get() 主動檢查異常，或實作 Thread.UncaughtExceptionHandler。

五、監控與運維關鍵指標

• getTaskCount()：總提交任務數
• getCompletedTaskCount()：已完成任務數
• getActiveCount()：當前執行中任務數
• getQueue().size()：佇列積壓數
• getPoolSize()：當前執行緒數
• getLargestPoolSize()：歷史峰值執行緒數

建議整合 Prometheus/Grafana 或 Spring Boot Actuator 建構線程池儀表板，設置佇列積壓、拒絕次數、執行緒數異常告警。

結語

掌握線程池「設計需求 → 工廠方法 → 核心參數 → 避坑指南 → 監控體系」完整知識鏈，才能在生產環境駕馭併發複雜度。下一篇將深入原始碼剖析 ThreadPoolExecutor 實現機制，揭秘動態調整、優雅關閉、擴展點設計的精髓，敬請期待。