您好,登錄后才能下訂單哦!
這篇文章主要講解了“springboot如何初始化通用線(xiàn)程池”,文中的講解內(nèi)容簡(jiǎn)單清晰,易于學(xué)習(xí)與理解,下面請(qǐng)大家跟著小編的思路慢慢深入,一起來(lái)研究和學(xué)習(xí)“springboot如何初始化通用線(xiàn)程池”吧!
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.scheduling.annotation.EnableAsync; import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; import java.util.concurrent.Executor; import java.util.concurrent.ThreadPoolExecutor; /** * @description : 通用線(xiàn)程池,用于異步執(zhí)行寫(xiě)操作不影響主線(xiàn)程 */ @Configuration @EnableAsync public class InitThread { //線(xiàn)程池維護(hù)線(xiàn)程的最少數(shù)量 private static final int CORE_POOL_SIZE = 10; //線(xiàn)程池維護(hù)線(xiàn)程的最大數(shù)量 private static final int MAX_POOL_SIZE = 50; //緩存隊(duì)列 private static final int QUEUE_CAPACITY = 10; //允許的空閑時(shí)間 private static final int KEEP_ALIVE = 60; @Bean public Executor myExecutor() { ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); executor.setCorePoolSize(CORE_POOL_SIZE); executor.setMaxPoolSize(MAX_POOL_SIZE); executor.setQueueCapacity(QUEUE_CAPACITY); executor.setThreadNamePrefix("executor-"); /* * 使用此策略,如果添加到線(xiàn)程池失敗,那么主線(xiàn)程會(huì)自己去執(zhí)行該任務(wù),不會(huì)等待線(xiàn)程池中的線(xiàn)程去執(zhí)行 */ executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); executor.setKeepAliveSeconds(KEEP_ALIVE); executor.initialize(); return executor; } }
拒絕策略RejectedExecutionHandler
AbortPolicy:該策略是線(xiàn)程池的默認(rèn)策略。使用該策略時(shí),如果線(xiàn)程池隊(duì)列滿(mǎn)了丟掉這個(gè)任務(wù)并且拋出RejectedExecutionException異常 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { //不做任何處理,直接拋出異常 throw new RejectedExecutionException("Task" + r.toString() + " rejected from " + e.toString()); } DiscardPolicy :這個(gè)策略和AbortPolicy的slient版本,如果線(xiàn)程池隊(duì)列滿(mǎn)了,會(huì)直接丟掉這個(gè)任務(wù)并且不會(huì)有任何異常。 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { //就是一個(gè)空的方法 } DiscardOldestPolicy :這個(gè)策略從字面上也很好理解,丟棄最老的。也就是說(shuō)如果隊(duì)列滿(mǎn)了,會(huì)將最早進(jìn)入隊(duì)列的任務(wù)刪掉騰出空間,再?lài)L試加入隊(duì)列。 因?yàn)殛?duì)列是隊(duì)尾進(jìn),隊(duì)頭出,所以隊(duì)頭元素是最老的,因此每次都是移除對(duì)頭元素后再?lài)L試入隊(duì)。 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { if (!e.isShutdown()) { //移除隊(duì)頭元素 e.getQueue().poll(); //再?lài)L試入隊(duì) e.execute(r); } } CallerRunsPolicy :使用此策略,如果添加到線(xiàn)程池失敗,那么主線(xiàn)程會(huì)自己去執(zhí)行該任務(wù),不會(huì)等待線(xiàn)程池中的線(xiàn)程去執(zhí)行。就像是個(gè)急脾氣的人,我等不到別人來(lái)做這件事就干脆自己干。 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { if (!e.isShutdown()) { //直接執(zhí)行run方法 r.run(); } } 自定義:只要實(shí)現(xiàn)RejectedExecutionHandler接口,并且實(shí)現(xiàn)rejectedExecution方法就可以了。具體的邏輯就在rejectedExecution方法里去定義就OK了 public class MyRejectPolicy implements RejectedExecutionHandler{ public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) { //Sender是我的Runnable類(lèi),里面有message字段 if (r instanceof Sender) { Sender sender = (Sender) r; //直接打印 System.out.println(sender.getMessage()); } } }
感謝各位的閱讀,以上就是“springboot如何初始化通用線(xiàn)程池”的內(nèi)容了,經(jīng)過(guò)本文的學(xué)習(xí)后,相信大家對(duì)springboot如何初始化通用線(xiàn)程池這一問(wèn)題有了更深刻的體會(huì),具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是億速云,小編將為大家推送更多相關(guān)知識(shí)點(diǎn)的文章,歡迎關(guān)注!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀(guān)點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。