ThreadPoolExecutor線程池的執(zhí)行原理

本文中主要對(duì)ThreadPoolExecutor講解

線程池的構(gòu)造參數(shù)

1、corePoolSize:核心線程數(shù)
2、maximumPoolSize:最大線程數(shù)
3、keepAliveTime:額外的線程的存活時(shí)間
4、workQueue:工作隊(duì)列,阻塞隊(duì)列
5、threadFactory:線程工廠,可指定線程名字
6、rejectedhandler:拒絕策略

線程池的關(guān)鍵方法

1、public void execute(Runnable command):提交任務(wù)到線程池
2、public Future<?> submit(Runnable task):可異步返回的方式提交任務(wù)到線程池
3、private boolean addWorker(Runnable firstTask, boolean core) :創(chuàng)建worker,即新建線程工作者,里面包裝了Thread
4、final void runWorker(Worker w):worker線程啟動(dòng)時(shí),執(zhí)行的真正方法,可消費(fèi)隊(duì)列中的任務(wù)
5、private Runnable getTask():獲取隊(duì)列中的任務(wù),注意poll和take的區(qū)別

線程池的執(zhí)行原理概述

圍繞線程池的主要參數(shù)和主要方法,總結(jié)線程池的執(zhí)行過(guò)程如下:

1、提交任務(wù)后,先判斷當(dāng)前池中線程數(shù)是否小于corePoolSize,如果小于,則創(chuàng)建新線程執(zhí)行這個(gè)任務(wù)。
2、如果大于corePoolSize,則判斷等待隊(duì)列是否已滿,如果沒(méi)有滿,則添加到等待隊(duì)列。
3、如果隊(duì)列已滿,判斷當(dāng)前池中線程數(shù)是否大于 maximumPoolSize,如果小于,則可以創(chuàng)建新線程執(zhí)行任務(wù)。如果大于,則不再創(chuàng)建新線程。如果大于則拒絕。
4、否則,創(chuàng)建一個(gè)新的線程執(zhí)行這個(gè)任務(wù)。
5、getTask方法中,核心線程使用take方式從隊(duì)列中獲取任務(wù),在不設(shè)置 allowCoreThreadTimeOut的情況下,將一直
阻塞,不會(huì)被回收。
6、非核心線程使用poll的方式從隊(duì)列中獲取任務(wù),經(jīng)過(guò)keepAliveTime后,還沒(méi)有拿到任務(wù),則非核心線程結(jié)束阻塞,
資源將被回收。

線程池的執(zhí)行原理流程圖

image.png
最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡(jiǎn)書(shū)系信息發(fā)布平臺(tái),僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容