Java多線程中的ThreadPoolExecutor解讀
corePoolSize
線程池中的核心線程數(shù)。當(dāng)提交一個(gè)任務(wù)時(shí),線程池創(chuàng)建一個(gè)新線程執(zhí)行任務(wù),直到當(dāng)前線程數(shù)等于corePoolSize;如果當(dāng)前線程數(shù)為corePoolSize,繼續(xù)提交的任務(wù)被保存到阻塞隊(duì)列中,等待被執(zhí)行。
maximumPoolSize
線程池中允許的最大線程數(shù)。如果當(dāng)前阻塞隊(duì)列滿了,且繼續(xù)提交任務(wù),則創(chuàng)建新的線程執(zhí)行任務(wù),前提是當(dāng)前線程數(shù)小于maximumPoolSize。
keepAliveTime
線程空閑時(shí)的存活時(shí)間。默認(rèn)情況下,只有當(dāng)線程池中的線程數(shù)大于corePoolSize時(shí),keepAliveTime才會(huì)起作用,如果一個(gè)線程空閑的時(shí)間達(dá)到keepAliveTime,則會(huì)終止,直到線程池中的線程數(shù)不超過(guò)corePoolSize。但是如果調(diào)用了allowCoreThreadTimeOut(boolean)方法,keepAliveTime參數(shù)也會(huì)起作用,直到線程池中的線程數(shù)為0。
unit
keepAliveTime參數(shù)的時(shí)間單位。
workQueue
任務(wù)緩存隊(duì)列,用來(lái)存放等待執(zhí)行的任務(wù)。如果當(dāng)前線程數(shù)為corePoolSize,繼續(xù)提交的任務(wù)就會(huì)被保存到任務(wù)緩存隊(duì)列中,等待被執(zhí)行。 一般來(lái)說(shuō),這里的BlockingQueue有以下三種選擇:
1.SynchronousQueue:一個(gè)不存儲(chǔ)元素的阻塞隊(duì)列,每個(gè)插入操作必須等到另一個(gè)線程調(diào)用移除操作,否則插入操作一直處于阻塞狀態(tài)。因此,如果線程池中始終沒(méi)有空閑線程(任務(wù)提交的平均速度快于被處理的速度),可能出現(xiàn)無(wú)限制的線程增長(zhǎng)。
2.LinkedBlockingQueue:基于鏈表結(jié)構(gòu)的阻塞隊(duì)列,如果不設(shè)置初始化容量,其容量為Integer.MAX_VALUE,即為無(wú)界隊(duì)列。因此,如果線程池中線程數(shù)達(dá)到了corePoolSize,且始終沒(méi)有空閑線程(任務(wù)提交的平均速度快于被處理的速度),任務(wù)緩存隊(duì)列可能出現(xiàn)無(wú)限制的增長(zhǎng)。
3.ArrayBlockingQueue:基于數(shù)組結(jié)構(gòu)的有界阻塞隊(duì)列,按FIFO排序任務(wù)。
threadFactory
線程工廠,創(chuàng)建新線程時(shí)使用的線程工廠。
handler
任務(wù)拒絕策略,當(dāng)阻塞隊(duì)列滿了,且線程池中的線程數(shù)達(dá)到maximumPoolSize,如果繼續(xù)提交任務(wù),就會(huì)采取任務(wù)拒絕策略處理該任務(wù),線程池提供了4種任務(wù)拒絕策略:
1.AbortPolicy:丟棄任務(wù)并拋出RejectedExecutionException異常,默認(rèn)策略;
2.CallerRunsPolicy:由調(diào)用execute方法的線程執(zhí)行該任務(wù);
3.DiscardPolicy:丟棄任務(wù),但是不拋出異常;
4.DiscardOldestPolicy:丟棄阻塞隊(duì)列最前面的任務(wù),然后重新嘗試執(zhí)行任務(wù)(重復(fù)此過(guò)程)。 當(dāng)然也可以根據(jù)應(yīng)用場(chǎng)景實(shí)現(xiàn)RejectedExecutionHandler接口,自定義飽和策略,如記錄日志或持久化存儲(chǔ)不能處理的任務(wù)。
public static void main(String[] args) {
int corePoolSize = 0;
int maximumPoolSize = 0;
long keepAliveTime = 0;
TimeUnit unit = TimeUnit.SECONDS;
//1.SynchronousQueue:一個(gè)不存儲(chǔ)元素的阻塞隊(duì)列,每個(gè)插入操作必須等到另一個(gè)線程調(diào)用移除操作,
//否則插入操作一直處于阻塞狀態(tài)。因此,如果線程池中始終沒(méi)有空閑線程(任務(wù)提交的平均速度快于被處理的速度),
//可能出現(xiàn)無(wú)限制的線程增長(zhǎng)。
//2.LinkedBlockingQueue:基于鏈表結(jié)構(gòu)的阻塞隊(duì)列,如果不設(shè)置初始化容量,
//其容量為Integer.MAX_VALUE,即為無(wú)界隊(duì)列。因此,如果線程池中線程數(shù)達(dá)到了corePoolSize,
//且始終沒(méi)有空閑線程(任務(wù)提交的平均速度快于被處理的速度),任務(wù)緩存隊(duì)列可能出現(xiàn)無(wú)限制的增長(zhǎng)。
//3.ArrayBlockingQueue:基于數(shù)組結(jié)構(gòu)的有界阻塞隊(duì)列,按FIFO排序任務(wù)。
BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<>(100);
ThreadFactory threadFactory = new ThreadFactory() {
@Override
public Thread newThread(Runnable r) {
return new Thread("newThread");
}
};
//1.AbortPolicy:丟棄任務(wù)并拋出RejectedExecutionException異常,默認(rèn)策略;
//2.CallerRunsPolicy:由調(diào)用execute方法的線程執(zhí)行該任務(wù);
//3.DiscardPolicy:丟棄任務(wù),但是不拋出異常;
//4.DiscardOldestPolicy:丟棄阻塞隊(duì)列最前面的任務(wù),然后重新嘗試執(zhí)行任務(wù)(重復(fù)此過(guò)程)。
RejectedExecutionHandler handler = new RejectedExecutionHandler() {
@Override
public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
}
};
ThreadPoolExecutor threadPoolExecutor =
new ThreadPoolExecutor(
corePoolSize,
maximumPoolSize,
keepAliveTime,
unit,
workQueue);
ThreadPoolExecutor threadPoolExecutor1 =
new ThreadPoolExecutor(
corePoolSize,
maximumPoolSize,
keepAliveTime,
unit,
workQueue,
threadFactory);
ThreadPoolExecutor threadPoolExecutor2 =
new ThreadPoolExecutor(
corePoolSize,
maximumPoolSize,
keepAliveTime,
unit,
workQueue,
handler);
ThreadPoolExecutor threadPoolExecutor3 =
new ThreadPoolExecutor(
corePoolSize,
maximumPoolSize,
keepAliveTime,
unit,
workQueue,
threadFactory,
handler);
}到此這篇關(guān)于Java多線程中的ThreadPoolExecutor解讀的文章就介紹到這了,更多相關(guān)ThreadPoolExecutor解讀內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
SpringBoot整合Guava Cache實(shí)現(xiàn)全局緩存的示例代碼
這篇文章主要介紹了SpringBoot整合Guava Cache實(shí)現(xiàn)全局緩存,Guava Cache是Google Guava庫(kù)中的一個(gè)模塊,提供了基于內(nèi)存的本地緩存實(shí)現(xiàn),文中介紹了SpringBoot整合使用Guava Cache的具體步驟,需要的朋友可以參考下2024-03-03
Python單元測(cè)試_使用裝飾器實(shí)現(xiàn)測(cè)試跳過(guò)和預(yù)期故障的方法
下面小編就為大家?guī)?lái)一篇Python單元測(cè)試_使用裝飾器實(shí)現(xiàn)測(cè)試跳過(guò)和預(yù)期故障的方法。小編覺(jué)得挺不錯(cuò)的,現(xiàn)在就分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2017-06-06
SpringBoot 嵌入式web容器的啟動(dòng)原理詳解
這篇文章主要介紹了SpringBoot 嵌入式web容器的啟動(dòng)原理詳解,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。2021-11-11
Maven中plugins與pluginManagement的區(qū)別說(shuō)明
這篇文章主要介紹了Maven中plugins與pluginManagement的區(qū)別說(shuō)明,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2021-09-09
springMVC如何將controller中數(shù)據(jù)傳遞到j(luò)sp頁(yè)面
這篇文章主要介紹了springMVC如何將controller中數(shù)據(jù)傳遞到j(luò)sp頁(yè)面,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2017-07-07
Java ByteBuffer網(wǎng)絡(luò)編程用法實(shí)例解析
這篇文章主要介紹了Java ByteBuffer網(wǎng)絡(luò)編程用法實(shí)例解析,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-10-10

