線程池隊(duì)列大小設(shè)置
發(fā)布時間：2025-11-13 | 來源：互聯(lián)網(wǎng)轉(zhuǎn)載和整理
一、ThreadPoolExecutor的重要參數(shù)
corePoolSize：核心線程數(shù)， 核心線程會一直存活，及時沒有任務(wù)需要執(zhí)行，當(dāng)線程數(shù)小于核心線程數(shù)時，即使有線程空閑，線程池也會優(yōu)先創(chuàng)建新線程處理，設(shè)置allowCoreThreadTimeout=true（默認(rèn)false）時，核心線程會超時關(guān)閉
queueCapacity：任務(wù)隊(duì)列容量（阻塞隊(duì)列）
當(dāng)核心線程數(shù)達(dá)到最大時，新任務(wù)會放在隊(duì)列中排隊(duì)等待執(zhí)行
maxPoolSize：最大線程數(shù)
當(dāng)線程數(shù)>=corePoolSize，且任務(wù)隊(duì)列已滿時。線程池會創(chuàng)建新線程來處理任務(wù)
當(dāng)線程數(shù)=maxPoolSize，且任務(wù)隊(duì)列已滿時，線程池會拒絕處理任務(wù)而拋出異常
keepAliveTime：線程空閑時間
當(dāng)線程空閑時間達(dá)到keepAliveTime時，線程會退出，直到線程數(shù)量=corePoolSize
如果allowCoreThreadTimeout=true，則會直到線程數(shù)量=0
allowCoreThreadTimeout：允許核心線程超時
rejectedExecutionHandler：任務(wù)拒絕處理器
兩種情況會拒絕處理任務(wù)：
當(dāng)線程數(shù)已經(jīng)達(dá)到maxPoolSize，切隊(duì)列已滿，會拒絕新任務(wù)
當(dāng)線程池被調(diào)用shutdown()后，會等待線程池里的任務(wù)執(zhí)行完畢，再shutdown。如果在調(diào)用shutdown()和線程池真正shutdown之間提交任務(wù)，會拒絕新任務(wù)
線程池會調(diào)用rejectedExecutionHandler來處理這個任務(wù)。如果沒有設(shè)置默認(rèn)是 AbortPolicy，會拋出異常
ThreadPoolExecutor類有幾個內(nèi)部實(shí)現(xiàn)類來處理這類情況：
AbortPolicy 丟棄任務(wù)，拋運(yùn)行時異常
CallerRunsPolicy 執(zhí)行任務(wù)
DiscardPolicy 忽視，什么都不會發(fā)生
DiscardOldestPolicy 從隊(duì)列中踢出最先進(jìn)入隊(duì)列（最后一個執(zhí)行）的任務(wù)
實(shí)現(xiàn)RejectedExecutionHandler接口，可自定義處理器
二、ThreadPoolExecutor執(zhí)行順序
線程池按以下行為執(zhí)行任務(wù)
（1）當(dāng)線程數(shù)小于核心線程數(shù)時，創(chuàng)建線程。
（2）當(dāng)線程數(shù)大于等于核心線程數(shù)，且任務(wù)隊(duì)列未滿時，將任務(wù)放入任務(wù)隊(duì)列。
（3）當(dāng)線程數(shù)大于等于核心線程數(shù)，且任務(wù)隊(duì)列已滿
1）若線程數(shù)小于最大線程數(shù)，創(chuàng)建線程
2）若線程數(shù)等于最大線程數(shù)，拋出異常，拒絕任務(wù)
三、如何設(shè)置參數(shù)
默認(rèn)值
corePoolSize=1
queueCapacity=Integer.MAX_VALUE
maxPoolSize=Integer.MAX_VALUE
keepAliveTime=60s
allowCoreThreadTimeout=false
rejectedExecutionHandler=AbortPolicy()
如何來設(shè)置
需要根據(jù)幾個值來決定
tasks ：每秒的任務(wù)數(shù)，假設(shè)為500~1000
taskcost：每個任務(wù)花費(fèi)時間，假設(shè)為0.1s
responsetime：系統(tǒng)允許容忍的最大響應(yīng)時間，假設(shè)為1s
做幾個計(jì)算
corePoolSize = 每秒需要多少個線程處理？
threadcount = tasks/(1/taskcost) =tasks*taskcout =(500~1000)*0.1 = 50~100 個線程。corePoolSize設(shè)置應(yīng)該大于50
根據(jù)8020原則，如果80%的每秒任務(wù)數(shù)小于800，那么corePoolSize設(shè)置為80即可
queueCapacity = (coreSizePool/taskcost)*responsetime
計(jì)算可得 queueCapacity = 80/0.1*1 = 80。意思是隊(duì)列里的線程可以等待1s，超過了的需要新開線程來執(zhí)行
切記不能設(shè)置為Integer.MAX_VALUE，這樣隊(duì)列會很大，線程數(shù)只會保持在corePoolSize大小，當(dāng)任務(wù)陡增時，不能新開線程來執(zhí)行，響應(yīng)時間會隨之陡增。
maxPoolSize = (max(tasks)- queueCapacity)/(1/taskcost)
計(jì)算可得 maxPoolSize = (1000-80)/10 = 92
（最大任務(wù)數(shù)-隊(duì)列容量）/每個線程每秒處理能力 = 最大線程數(shù)
rejectedExecutionHandler：根據(jù)具體情況來決定，任務(wù)不重要可丟棄，任務(wù)重要則要利用一些緩沖機(jī)制來處理
keepAliveTime和allowCoreThreadTimeout采用默認(rèn)通常能滿足