Java 線程池核心原理與實戰完整指南

線程池是 Java 並發編程的核心基礎設施，統一管理線程生命週期、任務隊列與執行策略。本文深度解析 ThreadPoolExecutor 核心參數、執行流程、源碼關鍵邏輯（Worker、工作隊列、拒絕策略），並提供生產級配置建議與監控方案。

為什麼需要線程池？

• 線程復用：避免頻繁創建/銷毀線程的系統開銷（記憶體、CPU 上下文切換）。
• 控制並發度：限制同時執行線程數，防止資源耗盡（OOM、CPU 打滿）。
• 任務管理：統一提交、排隊、異常處理、優先級、定時/周期執行。
• 監控可觀測：隊列積壓、活躍線程數、完成率等指標支撐容量規劃。

Executor 框架核心類結構

Executor (頂層接口)
  └─ ExecutorService
       ├─ AbstractExecutorService (模板方法)
       │    └─ ThreadPoolExecutor (核心實現)
       ├─ ScheduledExecutorService
       │    └─ ScheduledThreadPoolExecutor
       └─ ForkJoinPool (分治任務專用)
Executors (工廠類) → 提供預設配置的靜態工廠方法

ThreadPoolExecutor 七大核心參數

public ThreadPoolExecutor(
    int corePoolSize,           // 核心線程數（常駐）
    int maximumPoolSize,        // 最大線程數（含非核心）
    long keepAliveTime,         // 非核心線程閒置存活時間
    TimeUnit unit,              // 時間單位
    BlockingQueue workQueue, // 任務隊列
    ThreadFactory threadFactory,       // 線程創建工廠
    RejectedExecutionHandler handler   // 拒絕策略
)

參數選型指南

四大預設線程池工廠方法（及其缺陷）

阿里巴巴開發手冊強制規定：不允許使用 Executors 預設工廠，必須自定義 ThreadPoolExecutor。

任務執行流程圖解

submit(task)
    │
    ▼
corePoolSize 已滿？
    ├─ 否 → 創建核心線程執行 → 完成
    │
    └─ 是 → 嘗試入隊 (workQueue.offer)
              │
              ├─ 成功 → 等待核心線程拉取執行
              │
              └─ 失敗 (隊列滿) → maximumPoolSize 已滿？
                           ├─ 否 → 創建非核心線程執行
                           │
                           └─ 是 → 執行拒絕策略 (handler.rejectedExecution)

源碼關鍵點：Worker 與線程復用

// 簡化版 Worker.runWorker()
final void runWorker(Worker w) {
    Runnable task = w.firstTask;
    w.firstTask = null;
    // 關鍵：while 循環持續從隊列獲取任務
    while (task != null || (task = getTask()) != null) {
        w.lock(); // 可重入鎖，控制線程狀態
        try {
            beforeExecute(w.thread, task);
            task.run();           // 執行用戶任務
            afterExecute(task, null);
        } catch (RuntimeException x) {
            // 異常處理
        } finally {
            w.unlock();
            task = null;
        }
    }
    // 退出循環 → 線程結束 → 線程池回收 Worker
    processWorkerExit(w, completedAbruptly);
}

// getTask() 核心邏輯
private Runnable getTask() {
    boolean timed = allowCoreThreadTimeOut || workerCount > corePoolSize;
    for (;;) {
        // timed=true 使用 poll(keepAliveTime)，超時返回 null 觸發線程回收
        // timed=false 使用 take() 永久阻塞
        Runnable r = timed ? workQueue.poll(keepAliveTime, TimeUnit.NANOSECONDS)
                           : workQueue.take();
        if (r != null) return r;
        // 隊列空且超時 → 返回 null → Worker 退出
        if (workerCount > corePoolSize || allowCoreThreadTimeOut) return null;
    }
}

核心洞察：

• 線程復用靠 while (task = getTask()) 循環，而非線程結束後重建。
• allowCoreThreadTimeOut=true 可讓核心線程也超時回收，適合間歇性負載。
• workQueue.take() 阻塞等待，poll(timeout) 超時返回 null 觸發縮容。

常見工作隊列選型

四大內建拒絕策略

1. AbortPolicy (預設)：拋 RejectedExecutionException，調用者需捕獲。
2. CallerRunsPolicy：由調用線程執行任務，**天然削峰填谷**，推薦生產環境。
3. DiscardPolicy：靜默丟棄，任務丟失無感知，極少用。
4. DiscardOldestPolicy：丟棄隊列頭部最舊任務，嘗試重新提交，可能導致關鍵任務丟失。

自定義策略：實現 RejectedExecutionHandler，可記錄日誌、持久化到資料庫、發送告警、轉發到備用隊列。

關鍵監控指標

ThreadPoolExecutor executor = ...;
// 即時指標
int active = executor.getActiveCount();        // 正在執行任務的線程數
int poolSize = executor.getPoolSize();         // 當前線程池大小
int coreSize = executor.getCorePoolSize();     // 核心線程數
int maxSize = executor.getMaximumPoolSize();   // 最大線程數
long completed = executor.getCompletedTaskCount(); // 已完成任務數
long queued = executor.getQueue().size();      // 隊列積壓數
long total = executor.getTaskCount();          // 總提交任務數

// 衍生指標
double queueUtilization = (double) queued / queueCapacity;
double threadUtilization = (double) active / poolSize;
double rejectionRate = rejectedCount / total;

接入 Prometheus/Grafana 監控：active、queued、rejectionRate 設定告警閾值。

優雅關閉與生命週期管理

// 1. 停止接受新任務，處理完隊列任務
executor.shutdown();
try {
    if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
        // 2. 強制關閉，取消未執行任務，中斷執行中任務
        List remaining = executor.shutdownNow();
        // 記錄剩餘任務，決定是否持久化重試
        if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
            log.error("線程池未能在限定時間內關閉");
        }
    }
} catch (InterruptedException ex) {
    executor.shutdownNow();
    Thread.currentThread().interrupt();
}

Spring Boot 整合最佳實踐

@Configuration
@EnableAsync
public class ThreadPoolConfig {

    @Bean("businessExecutor")
    public ThreadPoolTaskExecutor businessExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(10);
        executor.setMaxPoolSize(20);
        executor.setQueueCapacity(200);           // 有界隊列
        executor.setKeepAliveSeconds(60);
        executor.setThreadNamePrefix("biz-");
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        executor.setWaitForTasksToCompleteOnShutdown(true); // 優雅關閉
        executor.setAwaitTerminationSeconds(60);
        executor.initialize();
        return executor;
    }
}

// 使用
@Async("businessExecutor")
public CompletableFuture processOrder(Order order) { ... }

總結：生產環境線程池配置清單

1. ✅ **拒絕 Executors 預設工廠**，顯式構建 ThreadPoolExecutor。
2. ✅ **有界隊列** (ArrayBlockingQueue) + **CallerRunsPolicy** 防禦流量洪峰。
3. ✅ 線程命名規範：business-module-%d，便於 Arthas/jstack 排查。
4. ✅ 核心/最大線程數依負載類型計算，配置外部化（Nacos/Apollo）。
5. ✅ 監控指標暴露：隊列積壓率、拒絕率、活躍線程比。
6. ✅ 優雅關閉：shutdown() → awaitTermination → shutdownNow()。
7. ✅ 異步任務統一異常處理：Thread.setDefaultUncaughtExceptionHandler 或 Spring AsyncUncaughtExceptionHandler。