您现在的位置：程式碼之家 >> 編程語言 > >> Java 程式設計 >> Java 相關知識

Java 線程池全解析：ExecutorService、ForkJoinPool 與實戰最佳實踐

編輯：Java 相關知識

前言

線程池是 Java 並發編程的核心基礎設施，能有效控制並發線程數量、減少線程創建銷毀開銷、提升系統吞吐量。本文系統講解 JDK 內置線程池工廠、Fork/Join 框架及生產環境配置建議。

1. Executors 工廠類創建的四種經典線程池

1.1 newCachedThreadPool() - 可緩存線程池

特點：線程數不固定，空閒線程 60 秒後回收，適合大量短期任務。
風險：高並發下可能創建過多線程導致 OOM。

ExecutorService cacheThreadPool = Executors.newCachedThreadPool();
// 提交任務
cacheThreadPool.execute(new Task());

1.2 newFixedThreadPool(int nThreads) - 固定大小線程池

特點：線程數固定，任務隊列無界（LinkedBlockingQueue），適合負載穩定的長期任務。
優勢：控制並發度，避免資源耗盡。

ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3);

1.3 newSingleThreadExecutor() - 單線程線程池

特點：僅有一個工作線程，任務按提交順序串行執行，保證線程安全。
等價於 newFixedThreadPool(1)。

1.4 newScheduledThreadPool(int corePoolSize) - 定時/周期任務線程池

特點：支持延遲執行與固定頻率/延遲周期執行。
核心方法：schedule、scheduleAtFixedRate、scheduleWithFixedDelay。

ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(3);
// 3 秒後執行一次
scheduledExecutorService.schedule(new Task(), 3, TimeUnit.SECONDS);
// 3 秒後開始，每 5 秒執行一次
scheduledExecutorService.scheduleAtFixedRate(new Task(), 3, 5, TimeUnit.SECONDS);

2. ForkJoinPool 與 ForkJoinTask - 分治並行計算

JDK 7 引入，專為「分治法」設計，適用於可遞歸分解的計算密集型任務。

2.1 核心類

ForkJoinPool：實現 ExecutorService，管理工作線程。
ForkJoinTask：抽象任務類，兩大子類：
- RecursiveAction：無返回值任務。
- RecursiveTask<V>：有返回值任務。

2.2 RecursiveAction 範例：並行打印 0-300

static class PrintTask extends RecursiveAction {
    private static final int THRESHOLD = 50;
    private int start, end;
    public PrintTask(int start, int end) { this.start = start; this.end = end; }
    @Override protected void compute() {
        if (end - start < THRESHOLD) {
            for (int i = start; i < end; i++) System.out.println(Thread.currentThread().getName() + " " + i);
        } else {
            int middle = (start + end) / 2;
            PrintTask left = new PrintTask(start, middle);
            PrintTask right = new PrintTask(middle, end);
            left.fork(); right.fork(); // 提交子任務並行執行
        }
    }
}

2.3 RecursiveTask 範例：並行求和 100 個整數

static class CalTask extends RecursiveTask<Integer> {
    private static final int THRESHOLD = 20;
    private int[] arr; private int start, end;
    public CalTask(int[] arr, int start, int end) { this.arr = arr; this.start = start; this.end = end; }
    @Override protected Integer compute() {
        if (end - start < THRESHOLD) {
            int sum = 0;
            for (int i = start; i < end; i++) sum += arr[i];
            return sum;
        } else {
            int middle = (start + end) / 2;
            CalTask left = new CalTask(arr, start, middle);
            CalTask right = new CalTask(arr, middle, end);
            left.fork(); right.fork();
            return left.join() + right.join(); // 合併結果
        }
    }
}

3. 生產環境配置建議

場景	推薦線程池	核心參數調優
CPU 密集型計算	FixedThreadPool / ForkJoinPool	核心線程數 = CPU 核心數 + 1
IO 密集型任務	FixedThreadPool / CachedThreadPool	核心線程數 = CPU 核心數 * (1 + 平均等待時間/平均工作時間)
定時任務	ScheduledThreadPool	corePoolSize 根據並發定時任務數設定
高並發短任務	自定義 ThreadPoolExecutor	有界隊列 + 拒絕策略 + 監控指標