Java 線程池 ThreadPoolExecutor 與阻塞隊列 BlockingQueue 核心機制詳解

為什麼需要線程池？

頻繁 `new Thread()` 弊端明顯：

• 創建/銷毀開銷大（核心切換、記憶體分配、OS 調度）。
• 無統一管理，線程數失控導致 OOM/CPU 競爭劇烈。
• 缺乏定時、周期、單線程串行等高級調度能力。

線程池優勢：線程複用、並發數控制、任務隊列緩衝、豐富調度策略。

核心架構：生產者-消費者模型

// 簡化結構
public class ThreadPoolExecutor extends AbstractExecutorService {
    private final BlockingQueue workQueue; // 任務隊列
    private final HashSet workers;           // 工作線程集合
    // Worker 實現 Runnable，run() 中循環 takeTask() 執行
}

• 生產者： 提交任務的執行緒 (`execute/submit`)。
• 消費者： `Worker` 線程，循環 `workQueue.take()` 獲取任務執行。
• 緩衝區： `BlockingQueue` 實現線程安全入隊/出隊、阻塞/超時/中斷語義。

BlockingQueue 核心介面與實現

七大 JDK 實現選型指南

1. ArrayBlockingQueue：有界陣列、公平/非公平鎖、FIFO。固定緩衝、可預測記憶體。
2. LinkedBlockingQueue：無界鏈表 (預設 `Integer.MAX_VALUE`)、雙鎖 (take/put 分離)、高吞吐。**注意：無界導致 maximumPoolSize 失效**。
3. PriorityBlockingQueue：無界、堆排序、需 `Comparable`/`Comparator`。任務優先級調度。
4. DelayQueue：無界、基於 `PriorityQueue`、元素實現 `Delayed`。定時/延遲任務 (如緩存過期、定時器)。
5. SynchronousQueue：零容量、直接移交、生產者阻塞直到消費者 `take`。**CachedThreadPool 默認隊列**，適合短任務高併發。
6. LinkedTransferQueue：無界、`TransferQueue` 介面、`transfer/tryTransfer` 顯式移交。生產者可選擇同步/異步移交。
7. LinkedBlockingDeque：雙端隊列、雙鎖、支援 `addFirst/Last`、`takeFirst/Last`。**工作竊取** 算法核心數據結構 (`ForkJoinPool`)。

ThreadPoolExecutor 參數調優決策樹

// 經典配置範本
// CPU 密集：core = max = Ncpu + 1，有界隊列
// IO 密集：core = 2*Ncpu，max = 4*Ncpu，無界/同步隊列
ExecutorService pool = new ThreadPoolExecutor(
    corePoolSize, maximumPoolSize, keepAliveTime, TimeUnit.SECONDS,
    new ArrayBlockingQueue<>(1000), // 有界，防 OOM
    new ThreadFactoryBuilder().setNameFormat("biz-%d").build(), // 命名
    new ThreadPoolExecutor.CallerRunsPolicy() // 背壓
);

關鍵原理：Worker 線程生命週期

final void runWorker(Worker w) {
    Runnable task = w.firstTask;
    w.firstTask = null;
    w.unlock(); // 釋放鎖，允許中斷
    try {
        while (task != null || (task = getTask()) != null) {
            w.lock(); // 執行任務前加鎖 (可中斷)
            try {
                beforeExecute(w.thread, task);
                task.run();
                afterExecute(task, null);
            } finally {
                task = null;
                w.unlock();
            }
        }
    } finally {
        processWorkerExit(w, completedAbruptly);
    }
}

// 獲取任務：阻塞/超時/關閉檢查
private Runnable getTask() {
    for (;;) {
        int wc = workerCountOf(ctl.get());
        boolean timed = allowCoreThreadTimeOut || wc > corePoolSize;
        if (wc > maximumPoolSize || (timed && timedOut))
            return null; // 線程退出
        Runnable r = timed ? workQueue.poll(keepAliveTime, TimeUnit.NANOSECONDS)
                           : workQueue.take();
        if (r != null) return r;
    }
}

生產級監控指標體系

常見坑與避坑指南

1. 無界隊列 + 固定 corePoolSize → 提交爆發時隊列無限增長 → OOM。修正：有界隊列或 SynchronousQueue。
2. 提交 `Runnable` 異常吞沒 → `Future.get()` 不調用、無 `UncaughtExceptionHandler` → 任務失敗無感知。修正：`submit(Callable)` + `Future.get()` 或統一異常處理器。
3. 線程池未關閉 → 非守護線程阻塞 JVM 退出。修正：`shutdown()` + `awaitTermination()` 或 `try-with-resources` (Java 19+ `ExecutorService` 實作 `AutoCloseable`)。
4. ThreadLocal 洩漏 → 線程複用導致上一任務 ThreadLocal 殘留。修正：任務結束 `remove()` 或 `InheritableThreadLocal` 謹慎用。

結語

`ThreadPoolExecutor` + `BlockingQueue` 是 Java 併發編程的基石。理解「參數如何影響擴容/縮容」、「隊列特性如何決定背壓行為」、「Worker 循環如何處理中斷/異常/退出」，才能從「配置參數」進階到「架構決策」。下一篇將實戰《動態線程池：基於配置中心的運行時參數熱更新與自適應擴縮容》。