Java線程池的拒絕策略實(shí)現(xiàn)詳解
一、簡(jiǎn)介
jdk1.5 版本新增了JUC并發(fā)編程包,大大的簡(jiǎn)化了傳統(tǒng)的多線程開(kāi)發(fā)。
Java線程池,是典型的池化思想的產(chǎn)物,類似的還有數(shù)據(jù)庫(kù)的連接池、redis的連接池等。池化思想,就是在初始的時(shí)候去申請(qǐng)資源,創(chuàng)建一批可使用的連接,這樣在使用的時(shí)候,就不必再進(jìn)行創(chuàng)建連接信息的開(kāi)銷了。舉個(gè)生活中鮮明的例子,在去著名洋快餐某基或者某勞的時(shí)候,配餐人員是字節(jié)從一個(gè)中間的保溫箱里面直接取,然后打包就好了。不用再臨時(shí)的來(lái)了一個(gè)單子,又要去拿原材料,又要去進(jìn)行加工。效率明顯的就是提高了很多。
既然是池子,那么必然的會(huì)存在最大值、初始值以及存活值等屬性。在達(dá)到某些特定條件的時(shí)候,再來(lái)請(qǐng)求的話,池子是如何進(jìn)行請(qǐng)求處理的呢?這里就引出了池的拒絕策略。一般的數(shù)據(jù)庫(kù)連接池在達(dá)到最大連接數(shù)的時(shí)候會(huì)默認(rèn)的等待特定的設(shè)置的時(shí)間或者直接就拋出異常。而本文中要闡述的線程池卻并非如此的策略,下面開(kāi)始展開(kāi)講解下。
二、線程池的拒絕策略
線程池中,有三個(gè)重要的參數(shù),決定影響了拒絕策略:corePoolSize - 核心線程數(shù),也即最小的線程數(shù)。workQueue - 阻塞隊(duì)列 。maximumPoolSize - 最大線程數(shù)
當(dāng)提交任務(wù)數(shù)大于 corePoolSize 的時(shí)候,會(huì)優(yōu)先將任務(wù)放到 workQueue 阻塞隊(duì)列中。當(dāng)阻塞隊(duì)列飽和后,會(huì)擴(kuò)充線程池中線程數(shù),直到達(dá)到 maximumPoolSize 最大線程數(shù)配置。此時(shí),再多余的任務(wù),則會(huì)觸發(fā)線程池的拒絕策略了。
總結(jié)起來(lái),也就是一句話,當(dāng)提交的任務(wù)數(shù)大于(workQueue.size() + maximumPoolSize ),就會(huì)觸發(fā)線程池的拒絕策略。
三、拒絕策略定義
拒絕策略提供頂級(jí)接口 RejectedExecutionHandler ,其中方法 rejectedExecution 即定制具體的拒絕策略的執(zhí)行邏輯。
jdk默認(rèn)提供了四種拒絕策略:CallerRunsPolicy - 當(dāng)觸發(fā)拒絕策略,只要線程池沒(méi)有關(guān)閉的話,則使用調(diào)用線程直接運(yùn)行任務(wù)。
一般并發(fā)比較小,性能要求不高,不允許失敗。但是,由于調(diào)用者自己運(yùn)行任務(wù),如果任務(wù)提交速度過(guò)快,可能導(dǎo)致程序阻塞,性能效率上必然的損失較大
AbortPolicy - 丟棄任務(wù),并拋出拒絕執(zhí)行 RejectedExecutionException 異常信息。線程池默認(rèn)的拒絕策略。必須處理好拋出的異常,否則會(huì)打斷當(dāng)前的執(zhí)行流程,影響后續(xù)的任務(wù)執(zhí)行。
DiscardPolicy - 直接丟棄,其他啥都沒(méi)有
DiscardOldestPolicy - 當(dāng)觸發(fā)拒絕策略,只要線程池沒(méi)有關(guān)閉的話,丟棄阻塞隊(duì)列 workQueue 中最老的一個(gè)任務(wù),并將新任務(wù)加入
四、測(cè)試代碼
1、AbortPolicy
package com.cfang; import java.util.concurrent.BlockingQueue; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.RejectedExecutionHandler; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; import lombok.extern.slf4j.Slf4j; @Slf4j public class T2 { public static void main(String[] args) throws Exception{ int corePoolSize = 5; int maximumPoolSize = 10; long keepAliveTime = 5; BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<Runnable>(10); RejectedExecutionHandler handler = new ThreadPoolExecutor.AbortPolicy(); ThreadPoolExecutor executor = new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, TimeUnit.SECONDS, workQueue, handler); for(int i=0; i<100; i++) { try { executor.execute(new Thread(() -> log.info(Thread.currentThread().getName() + " is running"))); } catch (Exception e) { log.error(e.getMessage()); } } executor.shutdown(); } }
如果 executor.execute()提交任務(wù),由于會(huì)拋出 RuntimeException,沒(méi)有try.catch處理異常信息的話,會(huì)中斷調(diào)用者的處理流程,后續(xù)任務(wù)得不到執(zhí)行(跑不完100個(gè))。可自行測(cè)試下。
2、CallerRunsPolicy
主體代碼同上,更換拒絕策略:
RejectedExecutionHandler handler = new ThreadPoolExecutor.CallerRunsPolicy();
運(yùn)行后,在控制臺(tái)console中能夠看到的是,會(huì)有一部分的數(shù)據(jù)打印,顯示的是 “main is running”,也即體現(xiàn)調(diào)用線程處理。
3、DiscardPolicy
更換拒絕策略
RejectedExecutionHandler handler = new ThreadPoolExecutor.DiscardPolicy();
直接丟棄任務(wù),實(shí)際運(yùn)行中,打印出的信息不會(huì)有100條。
4、DiscardOldestPolicy
同樣的,更換拒絕策略:
RejectedExecutionHandler handler = new ThreadPoolExecutor.DiscardOldestPolicy();
實(shí)際運(yùn)行,打印出的信息也會(huì)少于100條。
五、總結(jié)
四種拒絕策略是相互獨(dú)立無(wú)關(guān)的,選擇何種策略去執(zhí)行,還得結(jié)合具體的業(yè)務(wù)場(chǎng)景。實(shí)際工作中,一般直接使用 ExecutorService 的時(shí)候,都是使用的默認(rèn)的 defaultHandler ,也即 AbortPolicy 策略。
相關(guān)文章
構(gòu)建SpringBoot+MyBatis+Freemarker的項(xiàng)目詳解
在本篇內(nèi)容里小編給大家整理的是關(guān)于構(gòu)建SpringBoot+MyBatis+Freemarker的項(xiàng)目的具體步驟以及實(shí)例代碼,需要的朋友們參考下。2019-06-06SpringBoot之自定義啟動(dòng)異常堆棧信息打印方式
這篇文章主要介紹了SpringBoot之自定義啟動(dòng)異常堆棧信息打印方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2021-08-08SpringBoot2實(shí)現(xiàn)MessageQueue消息隊(duì)列
本文主要介紹了 SpringBoot2實(shí)現(xiàn)MessageQueue消息隊(duì)列,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2023-04-04SpringFox實(shí)現(xiàn)自動(dòng)生成RESTful?API文檔
在開(kāi)發(fā)?RESTful?API?時(shí),編寫(xiě)?API?文檔是一個(gè)重要的任務(wù),這篇文章為大家介紹了如何使用?SpringFox?自動(dòng)生成?RESTful?API?文檔,并提供示例代碼,需要的可以參考一下2023-06-06Java過(guò)濾器如何解決存儲(chǔ)型xss攻擊問(wèn)題
這篇文章主要介紹了Java過(guò)濾器如何解決存儲(chǔ)型xss攻擊問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-05-05SpringBoot + JPA @ManyToMany的操作要點(diǎn)說(shuō)明
這篇文章主要介紹了SpringBoot + JPA @ManyToMany的操作要點(diǎn)說(shuō)明,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2021-12-12