Java 併發編程系列：Executor 框架與線程池深度實踐

Executor 框架：Java 異步任務執行的基石

頻繁創建/銷毀線程開銷巨大，JDK 5 引入 Executor 框架，將「任務提交」與「任務執行」解耦，底層基於線程池實現，提供線程生命週期管理、任務隊列、拒絕策略等企業級能力，同時避免 this 逃逸風險。

核心組件架構

• 任務接口：Runnable（無返回值）、Callable<V>（有返回值、可拋異常）
• 執行器接口：Executor（單方法 execute）、ExecutorService（繼承 Executor，提供 submit、shutdown、invokeAll 等豐富管理方法）
• 工廠工具類：Executors 快速創建常用線程池
• 結果容器：Future<V> 代表異步計算結果，FutureTask 同時實現 Runnable 和 Future
• 核心實現：ThreadPoolExecutor、ScheduledThreadPoolExecutor

兩級調度模型

1. 應用層（用戶態）：Executor 將任務映射到固定數量的 Java 線程
2. 系統層（內核態）：OS 將 Java 線程映射到硬件 CPU 核心

Executors 工廠方法與線程池選型

ThreadPoolExecutor 核心參數解析

public ThreadPoolExecutor(
    int corePoolSize,      // 核心線程數（常駐）
    int maximumPoolSize,   // 最大線程數（峰值）
    long keepAliveTime,    // 非核心線程空閒存活時間
    TimeUnit unit,         // 時間單位
    BlockingQueue workQueue, // 任務隊列
    ThreadFactory factory, // 線程工廠（命名、守護屬性等）
    RejectedExecutionHandler handler   // 拒絕策略
)

執行流程：

1. 線程數 < corePoolSize → 創建核心線程執行
2. 線程數 ≥ corePoolSize → 任務入隊 workQueue
3. 隊列滿 & 線程數 < maximumPoolSize → 創建非核心線程執行
4. 隊列滿 & 線程數 = maximumPoolSize → 執行 RejectedExecutionHandler

常見拒絕策略：AbortPolicy（拋異常，默認）、CallerRunsPolicy（調用者執行）、DiscardPolicy（靜默丟棄）、DiscardOldestPolicy（丟棄最舊任務）。

實戰代碼範例

執行 Runnable 任務

ExecutorService executor = Executors.newCachedThreadPool();
for (int i = 0; i < 5; i++) {
    executor.execute(() -> System.out.println(Thread.currentThread().getName() + " is running"));
}
executor.shutdown(); // 平滑關閉：不接受新任務，等待已提交任務完成

執行 Callable 任務並獲取結果

ExecutorService executor = Executors.newCachedThreadPool();
List> futures = new ArrayList<>();
for (int i = 0; i < 5; i++) {
    final int id = i;
    futures.add(executor.submit(() -> {
        System.out.println(Thread.currentThread().getName() + " call method");
        return "Result-" + id;
    }));
}
for (Future f : futures) {
    try {
        System.out.println(f.get()); // 阻塞直到結果返回
    } catch (InterruptedException | ExecutionException e) {
        e.printStackTrace();
    }
}
executor.shutdown();

三大經典線程池深度剖析

FixedThreadPool

• 無界 LinkedBlockingQueue → 任務堆積風險（OOM），但線程數固定，資源可控
• 適用於 CPU 密集型、長耗時任務，需預估併發上限

CachedThreadPool

• SynchronousQueue 直接移交，無隊列緩衝
• 來任務無空閒線程即創建新線程，極端情況下線程數暴增耗盡 CPU/內存
• 適用於 IO 密集型、短耗時、突發性任務

ScheduledThreadPoolExecutor

• 繼承 ThreadPoolExecutor，使用 DelayQueue 存放 ScheduledFutureTask
• 任務包含 time（執行時間）、period（周期）、sequenceNumber（序號）
• 執行流程：取出到期任務 → 執行 → 更新下次執行時間 → 放回隊列
• 可替代 Timer，支援多線程並發定時任務，異常不影響其他任務

最佳實踐建議

1. 生產環境禁用 Executors 默認工廠（阿里開發手冊強制），自定義 ThreadPoolExecutor 明確參數，避免 OOM
2. 區分 CPU/IO 密集型：CPU 密集核心數 = CPU 核心數 +1；IO 密集核心數 = 2 * CPU 核心數（參考《Java 併發編程實戰》）
3. 有界隊列 + 拒絕策略：防止任務無限堆積，採用 CallerRunsPolicy 實現「削峰填谷」背壓
4. 線程命名：通過 ThreadFactory 設置有意義名稱（如 order-process-%d），便於排查問題
5. 優雅關閉：shutdown() + awaitTermination(timeout)，處理未完成任務
6. 監控指標：隊列積壓、活躍線程數、完成任務數、拒絕次數，接入 Prometheus/Grafana

總結

Executor 框架是 Java 併發編程的「瑞士軍刀」。理解 ThreadPoolExecutor 參數交互、隊列選型、拒絕策略，並根據業務特性（CPU/IO、延遲敏感度、吞吐要求）定制線程池，是構建高性能、穩定 Java 服務的必修課。