Java 線程池核心原理與實戰：從 JDK 內置到 Spring 整合的完整指南

3.2 任務提交執行流程（核心邏輯）

1. 若當前線程數 < corePoolSize，創建新線程執行（即使有空閒線程）；
2. 若線程數 = corePoolSize 且 workQueue 未滿，任務入隊；
3. 若線程數 > corePoolSize 且 workQueue 滿且線程數 < maximumPoolSize，創建新線程執行；
4. 若線程數 = maximumPoolSize 且 workQueue 滿，執行拒絕策略；
5. 非核心線程空閒超過 keepAliveTime 將被回收，動態調整池大小。

優先級順序：核心線程 → 任務隊列 → 最大線程 → 拒絕策略。

3.3 實戰代碼示例

public class ThreadTest {
    public static void main(String[] args) {
        List strList = new ArrayList<>();
        for (int i = 0; i < 100; i++) strList.add("String" + i);

        int threadNum = Math.min(strList.size(), 5);
        ThreadPoolExecutor executor = new ThreadPoolExecutor(
            2, threadNum, 300, TimeUnit.MILLISECONDS,
            new ArrayBlockingQueue(3),
            new ThreadPoolExecutor.CallerRunsPolicy()
        );

        for (int i = 0; i < threadNum; i++) {
            executor.execute(new PrintStringThread(i, strList, threadNum));
        }
        executor.shutdown();
    }
}

class PrintStringThread implements Runnable {
    private int num;
    private List strList;
    private int threadNum;

    public PrintStringThread(int num, List strList, int threadNum) {
        this.num = num;
        this.strList = strList;
        this.threadNum = threadNum;
    }

    @Override
    public void run() {
        int length = 0;
        for (String str : strList) {
            if (length % threadNum == num) {
                System.out.println("線程編號：" + num + "，字符串：" + str);
            }
            length++;
        }
    }
}

思考點：上述代碼有潛在缺陷（如任務分配邏輯、隊列大小與線程數關係），留待讀者分析。

四、Spring 線程池整合：兩種配置方式

4.1 編程式配置

ThreadPoolTaskExecutor poolTaskExecutor = new ThreadPoolTaskExecutor();
poolTaskExecutor.setQueueCapacity(200);       // 隊列容量
poolTaskExecutor.setCorePoolSize(5);          // 核心線程數
poolTaskExecutor.setMaxPoolSize(1000);        // 最大線程數
poolTaskExecutor.setKeepAliveSeconds(30000);  // 空閒存活秒數
poolTaskExecutor.initialize();

4.2 聲明式 XML 配置（推薦生產環境）

<bean id="poolTaskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
    <!-- 核心線程數，默認 1 -->
    <property name="corePoolSize" value="5" />
    <!-- 最大線程數，默認 Integer.MAX_VALUE -->
    <property name="maxPoolSize" value="50" />
    <!-- 隊列最大長度 -->
    <property name="queueCapacity" value="2000" />
    <!-- 空閒存活時間，默認 60s -->
    <property name="keepAliveSeconds" value="100" />
    <!-- 拒絕策略：AbortPolicy(拋異常) / CallerRunsPolicy(調用者執行) -->
    <property name="rejectedExecutionHandler">
        <bean class="java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy" />
    </property>
</bean>

Spring 的 ThreadPoolTaskExecutor 封裝了 ThreadPoolExecutor，提供更友好的配置體驗，支持與 Spring 生命周期綁定，推薦在 Spring 項目中使用。

五、線程池適用場景與避坑指南

• 適用：大量短小任務（如 HTTP 請求處理、數據庫操作、異步通知）；
• 不適用：長時間運行任務（如大文件下載、視頻轉碼），會佔用核心線程導致新任務排隊；
• 關鍵調優：根據業務類型（CPU 密集型 vs IO 密集型）設置 corePoolSize；監控隊列積壓、拒絕次數、線程存活情況；合理選擇拒絕策略（CallerRunsPolicy 可平滑降級）。

總結

線程池是 Java 高併發編程的基石。掌握 ThreadPoolExecutor 七大參數交互邏輯、理解 Spring 封裝的配置映射、根據業務特性合理規劃池參數，是構建穩定、高效後端系統的必修課。