原文鏈接:https://blog.csdn.net/qishiheyongshi/article/details/132155705
// 當(dāng)線程數(shù)量達(dá)到corePoolSize召庞,且workQueue隊列塞滿任務(wù)了之后她君,繼續(xù)創(chuàng)建線程身冀,但不能超過 maximumPoolSize
ThreadPoolExecutor tpe = new ThreadPoolExecutor(2, 3,
5, TimeUnit.SECONDS, //5 秒內(nèi)沒有任務(wù)要處理惩阶,非核心線程釋放掉
/**
* LinkedBlockingQueue、ArrayBlockingQueue钾埂,實測執(zhí)行結(jié)果沒發(fā)現(xiàn)不同
* 隊列中最多能存入的任務(wù)數(shù)量
* 當(dāng)所有的核心線程都在處理任務(wù)的時候河闰,新進(jìn)來的任務(wù)將放入隊列中,
* 如果隊列中放滿了褥紫,則新建額外的線程處理淤击,總線程數(shù)量不能超過maximumPoolSize
* 如果隊列未滿,則不會新建額外線程故源,只使用核心線程
*/
new LinkedBlockingQueue<Runnable>(6),
Executors.defaultThreadFactory(),// 默認(rèn)的線程工廠,通過 new Thread 產(chǎn)生線程
/**四個拒絕策略:當(dāng)線程數(shù)量達(dá)到maximumPoolSize大小汞贸,并且workQueue也已經(jīng)塞滿了任務(wù)的情況下绳军,線程池會調(diào)用handler拒絕策略來處理請求
* AbortPolicy:為線程池默認(rèn)的拒絕策略,該策略直接拋異常處理矢腻。
* DiscardPolicy:直接拋棄不處理门驾。
* DiscardOldestPolicy:丟棄隊列中最老的任務(wù)。
* CallerRunsPolicy:將任務(wù)分配給當(dāng)前執(zhí)行 execute 的方法線程來處理,如這個調(diào)用方法中表示 main方法主線程多柑。
*/
new ThreadPoolExecutor.CallerRunsPolicy());
//創(chuàng)建10個線程奶是,核心線程限制性,然后放入等待隊列竣灌,等待隊列放滿后再新建線程
for (int i = 0; i < 10; i++) {
tpe.execute(()->{
String name = Thread.currentThread().getName();
System.out.println(name);
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
});
}
// System.out.println(tpe.getQueue());
//
// System.out.println(tpe.getQueue());
tpe.shutdown();
}
線程池創(chuàng)建的七大參數(shù):
1聂沙、corePoolSize:線程池核心線程數(shù)量,核心線程不會被回收初嘹,即使沒有任務(wù)執(zhí)行及汉,也會保持空閑狀態(tài)。如果線程池中的線程少于此數(shù)目屯烦,則在執(zhí)行任務(wù)時創(chuàng)建坷随。
2、maximumPoolSize:當(dāng)線程數(shù)量達(dá)到corePoolSize驻龟,且workQueue隊列塞滿任務(wù)了之后温眉,繼續(xù)創(chuàng)建線程,但不能超過 maximumPoolSize翁狐。
3类溢、keepAliveTime:超過corePoolSize之后的“臨時線程”的存活時間。
4露懒、unit:keepAliveTime的單位豌骏。
5龟梦、workQueue:當(dāng)線程數(shù)超過corePoolSize時,新的任務(wù)會處在等待狀態(tài)窃躲,并存在workQueue中计贰,BlockingQueue是一個先進(jìn)先出的阻塞式隊列實現(xiàn),workQueue有以下幾種實現(xiàn):
(1)蒂窒、ArrayBlockingQueue 基于數(shù)組的有界阻塞隊列躁倒,按FIFO排序。新任務(wù)進(jìn)來后洒琢,會放到該隊列的隊尾秧秉,有界的數(shù)組可以防止資源耗盡問題。當(dāng)線程池中線程數(shù)量達(dá)到corePoolSize后衰抑,再有新任務(wù)進(jìn)來象迎,則會將任務(wù)放入該隊列的隊尾,等待被調(diào)度呛踊。如果隊列已經(jīng)是滿的砾淌,則創(chuàng)建一個新線程,如果線程數(shù)量已經(jīng)達(dá)到maxPoolSize谭网,則會執(zhí)行拒絕策略汪厨。
(2)、LinkedBlockingQuene基于鏈表的無界阻塞隊列(其實最大容量為Interger.MAX)愉择,按照FIFO排序劫乱。由于該隊列的近似無界性,當(dāng)線程池中線程數(shù)量達(dá)到corePoolSize后锥涕,再有新任務(wù)進(jìn)來衷戈,會一直存入該隊列,而不會去創(chuàng)建新線程直到maxPoolSize层坠,因此使用該工作隊列時脱惰,參數(shù)maxPoolSize其實是不起作用的。
(3)窿春、SynchronousQuene一個不緩存任務(wù)的阻塞隊列拉一,生產(chǎn)者放入一個任務(wù)必須等到消費者取出這個任務(wù)。也就是說新任務(wù)進(jìn)來時旧乞,不會緩存蔚润,而是直接被調(diào)度執(zhí)行該任務(wù),如果沒有可用線程尺栖,則創(chuàng)建新線程嫡纠,如果線程數(shù)量達(dá)到maxPoolSize,則執(zhí)行拒絕策略。
(4)除盏、PriorityBlockingQueue 具有優(yōu)先級的無界阻塞隊列叉橱,優(yōu)先級通過參數(shù)Comparator實現(xiàn)。
ArrayBlockingQueue和PriorityBlockingQueue一般很少使用
6者蠕、threadFactory:創(chuàng)建線程的工廠類窃祝,通常我們會自定義一個threadFactory設(shè)置線程的名稱,這樣我們就可以知道線程是由哪個工廠類創(chuàng)建的踱侣,可以快速定位粪小。
7、handler:線程池執(zhí)行拒絕策略抡句,當(dāng)線程數(shù)量達(dá)到maximumPoolSize大小探膊,并且workQueue也已經(jīng)塞滿了任務(wù)的情況下,線程池會調(diào)用handler拒絕策略來處理請求待榔。