org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor
是spring提供的線程池類
/**
* @author Jenson 2020-08-18
*/
@Configuration
@EnableAsync
public class AsyncConfiguration {
/**
* 聲明一個(gè)線程池
*
* @return 執(zhí)行器
*/
@Bean("executorBeanName")
public Executor asyncExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
//通過Runtime方法來獲取當(dāng)前服務(wù)器cpu內(nèi)核,根據(jù)cpu內(nèi)核來創(chuàng)建核心線程數(shù)和最大線程數(shù)
int threadCount = Runtime.getRuntime().availableProcessors();
//核心線程數(shù)5:線程池創(chuàng)建時(shí)候初始化的線程數(shù)(核心線程數(shù)最大不超過)
executor.setCorePoolSize(5);
//最大線程數(shù)5:線程池最大的線程數(shù)银还,只有在緩沖隊(duì)列滿了之后才會申請超過核心線程數(shù)的線程
executor.setMaxPoolSize(5);
//緩沖隊(duì)列500:用來緩沖執(zhí)行任務(wù)的隊(duì)列
executor.setQueueCapacity(500);
//允許線程的空閑時(shí)間60秒:當(dāng)超過了核心線程出之外的線程在空閑時(shí)間到達(dá)之后會被銷毀
executor.setKeepAliveSeconds(60);
//線程池名的前綴:設(shè)置好了之后可以方便我們定位處理任務(wù)所在的線程池
executor.setThreadNamePrefix("async01-");
//配置拒絕策略状原,線程池對拒絕任務(wù)(無線程可用)的處理策略
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy());//配置拒絕策略
executor.initialize();
return executor;
}
}
拒絕策略:
AbortPolicy:用于被拒絕任務(wù)的處理程序爷光,它將拋出RejectedExecutionException
CallerRunsPolicy:用于被拒絕任務(wù)的處理程序强衡,它直接在execute方法的調(diào)用線程中運(yùn)行被拒絕的任務(wù)端盆。
DiscardOldestPolicy:用于被拒絕任務(wù)的處理程序闪幽,它放棄最舊的未處理請求料皇,然后重試execute谓松。
DiscardPolicy:用于被拒絕任務(wù)的處理程序星压,默認(rèn)情況下它將丟棄被拒絕的任務(wù)。
執(zhí)行過程:
如果此時(shí)線程池中的數(shù)量小于corePoolSize鬼譬,即使線程池中的線程都處于空閑狀態(tài)娜膘,也要?jiǎng)?chuàng)建新的線程來處理被添加的任務(wù)。
如果此時(shí)線程池中的數(shù)量等于 corePoolSize优质,但是緩沖隊(duì)列 workQueue未滿竣贪,那么任務(wù)被放入緩沖隊(duì)列。
如果此時(shí)線程池中的數(shù)量大于corePoolSize巩螃,緩沖隊(duì)列workQueue滿演怎,并且線程池中的數(shù)量小于maxPoolSize,建新的線程來處理被添加的任務(wù)避乏。
如果此時(shí)線程池中的數(shù)量大于corePoolSize爷耀,緩沖隊(duì)列workQueue滿,并且線程池中的數(shù)量等于maxPoolSize拍皮,那么通過handler所指定的策略來處理此任務(wù)歹叮。也就是:處理任務(wù)的優(yōu)先級為:核心線程corePoolSize、任務(wù)隊(duì)列workQueue铆帽、最大線程 maximumPoolSize咆耿,如果三者都滿了,使用handler處理被拒絕的任務(wù)锄贼。
當(dāng)線程池中的線程數(shù)量大于corePoolSize時(shí)票灰,如果某線程空閑時(shí)間超過keepAliveTime,線程將被終止宅荤。這樣屑迂,線程池可以動態(tài)的調(diào)整池中的線程數(shù)。
核心線程數(shù)設(shè)置參考:
CPU密集型:核心線程數(shù) = CPU核數(shù) + 1
IO密集型:核心線程數(shù) = CPU核數(shù) * 2
什么是CPU密集型冯键?什么是IO密集型惹盼?
https://blog.csdn.net/youanyyou/article/details/78990156
CPU密集型也叫計(jì)算密集型,計(jì)算密集型任務(wù)的特點(diǎn)是要進(jìn)行大量的計(jì)算惫确,消耗CPU資源手报,這種計(jì)算密集型任務(wù)雖然也可以用多任務(wù)完成,但是任務(wù)越多改化,花在任務(wù)切換的時(shí)間就越多掩蛤,CPU執(zhí)行任務(wù)的效率就越低,所以陈肛,要最高效地利用CPU揍鸟,計(jì)算密集型任務(wù)同時(shí)進(jìn)行的數(shù)量應(yīng)當(dāng)?shù)扔贑PU的核心數(shù)。
IO密集型句旱,涉及到網(wǎng)絡(luò)阳藻、磁盤IO的任務(wù)都是IO密集型任務(wù)晰奖,這類任務(wù)的特點(diǎn)是CPU消耗很少,任務(wù)的大部分時(shí)間都在等待IO操作完成(因?yàn)镮O的速度遠(yuǎn)遠(yuǎn)低于CPU和內(nèi)存的速度)腥泥。對于IO密集型任務(wù)匾南,任務(wù)越多,CPU效率越高蛔外,但也有一個(gè)限度蛆楞。
參考:
https://blog.csdn.net/weixin_43168010/article/details/97613895
https://www.cnblogs.com/redcool/p/6426173.html
https://blog.csdn.net/lifulian318/article/details/109000675
補(bǔ)充:拒絕策略使用場景和其他第三方拒絕策略,參考:https://blog.csdn.net/zj57356498318/article/details/102579980