Java 線程池完整指南：四大類型原理、使用場景與最佳實踐

為什麼需要線程池

new Thread() 的弊端

• 頻繁建立/銷毀開銷大：系統呼叫、棧分配、上下文切換
• 無統一管理：可能無限制建立線程，導致資源耗盡（OOM）、CPU 搶佔、死鎖風險
• 功能匱乏：無定時、週期、優先級、中斷等進階控制

線程池優勢

• 重用線程**：減少建立/銷毀開銷，提升響應速度
• 控制併發上限**：避免資源過載，實現背壓
• 豐富功能**：定時、週期、單線程序列化、可配置拒絕策略

線程池類體系架構

• Executor：頂層介面，單一方法 execute(Runnable)，非線程池，僅執行工具
• ExecutorService：真正的線程池介面，繼承 Executor，提供生命週期管理、提交任務、關閉等
• ThreadPoolExecutor：核心實現類，高度可配置
• ScheduledExecutorService：支援定時/週期任務
• Executors：工廠類，提供四大預設配置

四大預設線程池詳細解析

1. newCachedThreadPool — 彈性快取池

ExecutorService cached = Executors.newCachedThreadPool();

特性：

• 核心線程數 = 0，最大線程數 = Integer.MAX_VALUE
• 空閒線程 60 秒回收（SynchronousQueue 直接移交）
• 適合**大量短期非同步任務**

風險：無上限，任務提交速度 > 處理速度時會瘋狂建立線程 → OOM。生產環境慎用或包裝限制。

// 測試：5個任務間隔1秒，觀察線程重用
cached.execute(() -> System.out.println(Thread.currentThread().getName()));
// 輸出：pool-1-thread-1 (重用同一線程)

2. newFixedThreadPool — 固定大小池

ExecutorService fixed = Executors.newFixedThreadPool(3);

特性：

• 核心 = 最大 = n，LinkedBlockingQueue 無界隊列
• 線程常駐不回收，任務排隊等待
• 適合**長時間運行、需控制併發度**的任務

風險：無界隊列積壓大量任務 → 記憶體飆升。提交速度持續 > 處理速度時同樣危險。

// 測試：5個任務，每個睡2秒，固定3線程
// 輸出前3個立即執行，2秒後執行後2個

3. newScheduledThreadPool — 定時/週期池

ScheduledExecutorService scheduled = Executors.newScheduledThreadPool(3);

特性：支援延遲執行、固定頻率、固定延遲三種模式。

// 延遲 3 秒執行一次
scheduled.schedule(() -> System.out.println("延遲3秒"), 3, TimeUnit.SECONDS);

// 延遲 1 秒後，每 3 秒執行一次（固定頻率）
scheduled.scheduleAtFixedRate(() -> System.out.println("週期執行"), 1, 3, TimeUnit.SECONDS);

// 延遲 1 秒後，每次執行結束 3 秒後再執行（固定延遲）
scheduled.scheduleWithFixedDelay(() -> System.out.println("固定延遲"), 1, 3, TimeUnit.SECONDS);

區別：scheduleAtFixedRate 以**開始時間**為基準，執行時間長可能導致重疊；scheduleWithFixedDelay 以**結束時間**為基準，無重疊風險。

4. newSingleThreadExecutor — 單線程序列化池

ExecutorService single = Executors.newSingleThreadExecutor();

特性：

• 核心 = 最大 = 1，無界隊列
• **嚴格保證任務循序執行**，同一時間僅一線程活躍
• 線程異常終止會自動建立新線程繼續
• 適合**需要序列化處理**的場景（如日誌寫入、資料庫同步）

優於 newFixedThreadPool(1)：不可重新配置為多線程，語義更清晰、防誤用。

ThreadPoolExecutor 七大核心參數（自訂線程池關鍵）

new ThreadPoolExecutor(
    corePoolSize,       // 核心線程數（常駐）
    maximumPoolSize,    // 最大線程數
    keepAliveTime,      // 非核心線程空閒存活時間
    unit,               // 時間單位
    workQueue,          // 任務隊列（關鍵！）
    threadFactory,      // 線程工廠（命名、優先級、守護線程）
    handler             // 拒絕策略（隊列滿 + 線程達最大時）
);

隊列選型決定行為

四大拒絕策略

• AbortPolicy（預設）：拋 RejectedExecutionException
• CallerRunsPolicy：呼叫者執行緒執行任務（自然背壓）
• DiscardPolicy：靜默丟棄新任務
• DiscardOldestPolicy：丟棄隊列最舊任務，嘗試重新提交

生產級線程池配置範例

@Configuration
public class ThreadPoolConfig {

    @Bean("businessExecutor")
    public ThreadPoolExecutor businessExecutor() {
        return new ThreadPoolExecutor(
            10,                    // 核心：CPU 核心數 * (1 + 平均等待/計算比)
            20,                    // 最大：核心 * 2 或根據壓測調整
            60, TimeUnit.SECONDS,  // 存活時間
            new ArrayBlockingQueue<>(500),  // 有界隊列：防 OOM
            new CustomThreadFactory("biz-"), // 可見命名：biz-1, biz-2...
            new ThreadPoolExecutor.CallerRunsPolicy()  // 背壓：呼叫者執行
        );
    }
    
    // 优雅關閉
    @PreDestroy
    public void shutdown() {
        businessExecutor().shutdown();
        try {
            if (!businessExecutor().awaitTermination(30, TimeUnit.SECONDS)) {
                businessExecutor().shutdownNow();
            }
        } catch (InterruptedException e) {
            businessExecutor().shutdownNow();
        }
    }
}

核心參數調優公式

• CPU 密集型：corePoolSize = CPU 核心數 + 1
• IO 密集型：corePoolSize = CPU 核心數 * (1 + 平均等待時間 / 平均工作時間)
• 實務中：**壓測決定**，而非公式推導

監控與觀測關鍵指標

總結與選型建議

**核心原則**：**顯式配置優於隱式預設**，**有界隊列優於無界**，**監控告警優於事後排查**。線程池是系統穩定性的基石，投入精力精心設計配置，回報率極高。