ThreadPoolExecutor的核心參數(shù)包括corePoolSize、maximumPoolSize、keepAliveTime、workQueue和handler，它們共同決定了線程池的行為。 1. corePoolSize指定核心線程數(shù)，即使空閑也不會(huì)被回收（除非啟用allowCoreThreadTimeOut）；2. maximumPoolSize定義最大線程數(shù)，控制線程池的上限；3. keepAliveTime設(shè)定非核心線程的空閑超時(shí)時(shí)間；4. workQueue決定任務(wù)的排隊(duì)策略，如使用有界隊(duì)列ArrayBlockingQueue可防止資源耗盡；5. handler用于處理無(wú)法接受新任務(wù)時(shí)的拒絕策略，推薦CallerRunsPolicy以實(shí)現(xiàn)背壓機(jī)制。合理設(shè)置這些參數(shù)并理解其影響，有助于避免內(nèi)存溢出、提升系統(tǒng)穩(wěn)定性，并在應(yīng)用關(guān)閉時(shí)通過(guò)shutdown()和awaitTermination確保任務(wù)完成，從而充分發(fā)揮線程池的價(jià)值。

Java的線程池執(zhí)行器（ThreadPoolExecutor）是并發(fā)編程中的核心組件之一，合理使用可以顯著提升程序性能。但很多人只是知道Executors工具類(lèi)能快速創(chuàng)建幾種常見(jiàn)的線程池，卻忽略了ThreadPoolExecutor本身提供的靈活性和控制能力。

核心參數(shù)搞清楚，別只靠默認(rèn)值

ThreadPoolExecutor的構(gòu)造函數(shù)有七個(gè)參數(shù)，其中最關(guān)鍵的是以下幾個(gè)：

• corePoolSize ：核心線程數(shù)，即使空閑也不會(huì)超時(shí)釋放（除非設(shè)置了allowCoreThreadTimeOut）
• maximumPoolSize ：最大線程數(shù)，線程池最多容納多少線程
• keepAliveTime ：非核心線程空閑多久后會(huì)被回收
• workQueue ：任務(wù)隊(duì)列，用來(lái)存放等待執(zhí)行的任務(wù)
• handler ：拒絕策略，當(dāng)任務(wù)無(wú)法提交時(shí)的處理方式

舉個(gè)例子：如果你設(shè)置corePoolSize為5，maximumPoolSize為10，workQueue容量為100，那前100個(gè)任務(wù)都會(huì)進(jìn)隊(duì)列，不會(huì)立即創(chuàng)建超過(guò)corePoolSize的線程，直到隊(duì)列滿了才會(huì)考慮創(chuàng)建新線程，直到達(dá)到maximumPoolSize。

很多新手直接用Executors.newFixedThreadPool(10) ，看起來(lái)沒(méi)問(wèn)題，但它的隊(duì)列是無(wú)界隊(duì)列，可能導(dǎo)致內(nèi)存溢出。自己用ThreadPoolExecutor的話，就可以更謹(jǐn)慎地控制這些行為。

任務(wù)隊(duì)列選型，影響線程池行為的關(guān)鍵點(diǎn)

任務(wù)隊(duì)列的選擇直接影響線程池如何調(diào)度任務(wù)。常用的隊(duì)列包括：

• LinkedBlockingQueue ：默認(rèn)無(wú)界，適合大多數(shù)場(chǎng)景，但可能隱藏資源耗盡的問(wèn)題
• ArrayBlockingQueue ：有界隊(duì)列，可以更好地控制資源上限，避免系統(tǒng)過(guò)載
• SynchronousQueue ：不存儲(chǔ)元素，每個(gè)插入操作必須等到另一個(gè)線程取出，適合高并發(fā)、低延遲場(chǎng)景
• PriorityBlockingQueue ：按優(yōu)先級(jí)排序的任務(wù)隊(duì)列，適合需要?jiǎng)討B(tài)調(diào)整任務(wù)順序的場(chǎng)景

建議根據(jù)實(shí)際負(fù)載選擇合適的隊(duì)列類(lèi)型。比如在Web服務(wù)器中處理請(qǐng)求時(shí)，使用有界隊(duì)列配合合適的拒絕策略（如CallerRunsPolicy），可以在壓力大時(shí)讓調(diào)用線程自己處理任務(wù)，起到限流作用。

拒絕策略不是擺設(shè)，關(guān)鍵時(shí)刻要起作用

當(dāng)線程池和任務(wù)隊(duì)列都滿的時(shí)候，就需要通過(guò)拒絕策略來(lái)應(yīng)對(duì)新任務(wù)。 JDK內(nèi)置了四種策略：

• AbortPolicy ：拋出異常，默認(rèn)行為
• CallerRunsPolicy ：由調(diào)用線程自己執(zhí)行任務(wù)
• DiscardPolicy ：默默丟棄任務(wù)
• DiscardOldestPolicy ：丟棄隊(duì)列中最老的任務(wù)，然后嘗試重新提交當(dāng)前任務(wù)

實(shí)際應(yīng)用中，最推薦的是CallerRunsPolicy ，因?yàn)樗梢宰屔嫌螠p緩任務(wù)提交速度，形成一種“背壓”機(jī)制，而不是簡(jiǎn)單地丟棄或拋異常。

當(dāng)然，你也可以自定義Handler，記錄日志、報(bào)警或者做其他處理。

線程池生命周期管理，別忘了關(guān)閉

很多人寫(xiě)完線程池就不管了，其實(shí)線程池也需要妥善關(guān)閉。主要方法有兩個(gè)：

• shutdown() ：不再接受新任務(wù)，但會(huì)等已提交任務(wù)執(zhí)行完畢
• shutdownNow() ：嘗試中斷所有正在執(zhí)行的任務(wù)，并返回等待執(zhí)行的任務(wù)列表

建議在應(yīng)用關(guān)閉時(shí)調(diào)用shutdown() ，并配合awaitTermination做等待，確保任務(wù)完成：

 executor.shutdown();
try {
    if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
        executor.shutdownNow();
    }
} catch (InterruptedException e) {
    executor.shutdownNow();
}

這樣可以盡量避免任務(wù)被強(qiáng)行中斷，保證數(shù)據(jù)一致性。

基本上就這些。 ThreadPoolExecutor功能強(qiáng)大，但也容易誤用，理解每個(gè)參數(shù)的作用和背后的機(jī)制，才能真正發(fā)揮它的價(jià)值。

以上是深入研究Java線程池執(zhí)行者的詳細(xì)內(nèi)容。更多信息請(qǐng)關(guān)注PHP中文網(wǎng)其他相關(guān)文章！