1. springboot 線程池介紹
Spring Boot項(xiàng)目中,可以用Springboot提供的對(duì)ThreadPoolExecutor封裝的ThreadPoolTaskExecutor,springboot對(duì)其進(jìn)行了簡(jiǎn)化處理,在配置類(lèi)或直接在程序入口類(lèi)上聲明注解@EnableAsync。然后在由Spring管理的對(duì)象的方法上標(biāo)注注解@Async,顯式調(diào)用即可生效。
如果此時(shí)線程池中的數(shù)量小于corePoolSize,即使線程池中的線程都處于空閑狀態(tài),也要?jiǎng)?chuàng)建新的線程來(lái)處理被添加的任務(wù)。
如果此時(shí)線程池中的數(shù)量等于 corePoolSize,但是緩沖隊(duì)列 workQueue未滿,那么任務(wù)被放入緩沖隊(duì)列。
如果此時(shí)線程池中的數(shù)量大于corePoolSize,緩沖隊(duì)列workQueue滿,并且線程池中的數(shù)量小于maximumPoolSize,建新的線程來(lái)處理被添加的任務(wù)。
如果此時(shí)線程池中的數(shù)量大于corePoolSize,緩沖隊(duì)列workQueue滿,并且線程池中的數(shù)量等于maximumPoolSize,那么通過(guò) handler所指定的策略來(lái)處理此任務(wù)。也就是:處理任務(wù)的優(yōu)先級(jí)為:核心線程corePoolSize、任務(wù)隊(duì)列workQueue、最大線程 maximumPoolSize,如果三者都滿了,使用handler處理被拒絕的任務(wù)。
當(dāng)線程池中的線程數(shù)量大于 corePoolSize時(shí),如果某線程空閑時(shí)間超過(guò)keepAliveTime,線程將被終止。這樣,線程池可以動(dòng)態(tài)的調(diào)整池中的線程數(shù)。
以下情況線程池會(huì)拒絕任務(wù):
(1).當(dāng)線程數(shù)已經(jīng)達(dá)到maxPoolSize,切隊(duì)列已滿,會(huì)拒絕新任務(wù)
(2).當(dāng)線程池被調(diào)用shutdown()后,會(huì)等待線程池里的任務(wù)執(zhí)行完畢,再shutdown。如果在調(diào)用shutdown()和線程池真正shutdown之間提交任務(wù),會(huì)拒絕新任務(wù),線程池會(huì)調(diào)用rejectedExecutionHandler來(lái)處理這個(gè)任務(wù)。如果沒(méi)有設(shè)置默認(rèn)是AbortPolicy,會(huì)拋出異常
ThreadPoolExecutor類(lèi)有幾個(gè)內(nèi)部實(shí)現(xiàn)類(lèi)來(lái)處理這類(lèi)情況:
1.AbortPolicy 丟棄任務(wù),拋運(yùn)行時(shí)異常
2.CallerRunsPolicy 執(zhí)行任務(wù)
3.DiscardPolicy 忽視,什么都不會(huì)發(fā)生
4.DiscardOldestPolicy 從隊(duì)列中踢出最先進(jìn)入隊(duì)列(最后一個(gè)執(zhí)行)的任務(wù)實(shí)現(xiàn)RejectedExecutionHandler接口,可自定義處理器





注意事項(xiàng),如下方式會(huì)使@Async失效
1.異步方法使用static修飾
2.異步類(lèi)沒(méi)有使用@Component注解(或其他注解)導(dǎo)致spring無(wú)法掃描到異步類(lèi)
3.異步方法不能與被調(diào)用的異步方法在同一個(gè)類(lèi)中
4.類(lèi)中需要使用@Autowired或@Resource等注解自動(dòng)注入,不能自己手動(dòng)new對(duì)象
5.如果使用SpringBoot框架必須在啟動(dòng)類(lèi)中增加@EnableAsync注解