java executor_Java并发编程(08):Executor线程池框架
一、Executor框架簡(jiǎn)介
1、基礎(chǔ)簡(jiǎn)介
Executor系統(tǒng)中,將線程任務(wù)提交和任務(wù)執(zhí)行進(jìn)行了解耦的設(shè)計(jì),Executor有各種功能強(qiáng)大的實(shí)現(xiàn)類,提供便捷方式來提交任務(wù)并且獲取任務(wù)執(zhí)行結(jié)果,封裝了任務(wù)執(zhí)行的過程,不再需要Thread().start()方式,顯式創(chuàng)建線程并關(guān)聯(lián)執(zhí)行任務(wù)。
2、調(diào)度模型
線程被一對(duì)一映射為服務(wù)所在操作系統(tǒng)線程,啟動(dòng)時(shí)會(huì)創(chuàng)建一個(gè)操作系統(tǒng)線程;當(dāng)該線程終止時(shí),這個(gè)操作系統(tǒng)線程也會(huì)被回收。
3、核心API結(jié)構(gòu)
Executor框架包含的核心接口和主要的實(shí)現(xiàn)類如下圖所示:
線程池任務(wù):核心接口:Runnable、Callable接口和接口實(shí)現(xiàn)類;
任務(wù)的結(jié)果:接口Future和實(shí)現(xiàn)類FutureTask;
任務(wù)的執(zhí)行:核心接口Executor和ExecutorService接口。在Executor框架中有兩個(gè)核心類實(shí)現(xiàn)了ExecutorService接口,ThreadPoolExecutor和ScheduledThreadPoolExecutor。
二、用法案例
1、API基礎(chǔ)
ThreadPoolExecutor基礎(chǔ)構(gòu)造
public2、初始化方法
ExecutorService通常情況下,線程池不允許使用Executors去創(chuàng)建,而是通過ThreadPoolExecutor的方式,這樣的處理方式更加明確線程池的運(yùn)行規(guī)則,規(guī)避資源耗盡的風(fēng)險(xiǎn)。
3、基礎(chǔ)案例
package流程分析
- 線程池中線程數(shù)小于corePoolSize時(shí),新任務(wù)將創(chuàng)建一個(gè)新線程執(zhí)行任務(wù),不論此時(shí)線程池中存在空閑線程;
- 線程池中線程數(shù)達(dá)到corePoolSize時(shí),新任務(wù)將被放入workQueue中,等待線程池中任務(wù)調(diào)度執(zhí)行;
- 當(dāng)workQueue已滿,且maximumPoolSize>corePoolSize時(shí),新任務(wù)會(huì)創(chuàng)建新線程執(zhí)行任務(wù);
- 當(dāng)workQueue已滿,且提交任務(wù)數(shù)超過maximumPoolSize,任務(wù)由RejectedExecutionHandler處理;
- 當(dāng)線程池中線程數(shù)超過corePoolSize,且超過這部分的空閑時(shí)間達(dá)到keepAliveTime時(shí),回收該線程;
- 如果設(shè)置allowCoreThreadTimeOut(true)時(shí),線程池中corePoolSize范圍內(nèi)的線程空閑時(shí)間達(dá)到keepAliveTime也將回收;
三、線程池應(yīng)用
應(yīng)用場(chǎng)景:批量賬戶和密碼的校驗(yàn)任務(wù),在實(shí)際的業(yè)務(wù)中算比較常見的,通過初始化線程池,把任務(wù)提交執(zhí)行,最后拿到處理結(jié)果,這就是線程池使用的核心思想:節(jié)省資源提升效率。
public線程池主要用來解決線程生命周期開銷問題和資源不足問題,通過線程池對(duì)多個(gè)任務(wù)線程重復(fù)使用,線程創(chuàng)建也被分?jǐn)偟蕉鄠€(gè)任務(wù)上,多數(shù)任務(wù)提交就有空閑的線程可以使用,所以消除線程頻繁創(chuàng)建帶來的開銷。
總結(jié)
以上是生活随笔為你收集整理的java executor_Java并发编程(08):Executor线程池框架的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 获取阿里云docker加速器地址
- 下一篇: java stringutils_Jav