線程池技術(shù)在并發(fā)時(shí)經(jīng)常會(huì)使用到，java中的線程池的使用是通過調(diào)用ThreadPoolExecutor來實(shí)現(xiàn)的。ThreadPoolExecutor提供了四個(gè)構(gòu)造函數(shù),最后都會(huì)歸結(jié)于下面這個(gè)構(gòu)造方法：

// 七個(gè)參數(shù)的構(gòu)造函數(shù)
public ThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory,
RejectedExecutionHandler handler)

這些參數(shù)的意義如下：

• corePoolSize：該線程池中核心線程數(shù)最大值
• maximumPoolSize： 該線程池中線程總數(shù)最大值
• keepAliveTime：該線程池中非核心線程閑置超時(shí)時(shí)長
• unit：keepAliveTime的單位
• workQueue：阻塞隊(duì)列BlockingQueue，維護(hù)著等待執(zhí)行的Runnable對象
• threadFactory：創(chuàng)建線程的接口，需要實(shí)現(xiàn)他的Thread newThread(Runnable r)方法。
• RejectedExecutionHandler：飽和策略，最大線程和工作隊(duì)列容量且已經(jīng)飽和時(shí)execute方法都將調(diào)用RejectedExecutionHandler 。

ThreadPoolExecutor工作流程

流程圖如下：

大致過程陳述為：

1. 向線程池中添加任務(wù)，當(dāng)任務(wù)數(shù)量少于corePoolSize時(shí)，會(huì)自動(dòng)創(chuàng)建thead來處理這些任務(wù)；
2. 當(dāng)添加任務(wù)數(shù)大于corePoolSize且少于maximmPoolSize時(shí)，不在創(chuàng)建線程，而是將這些任務(wù)放到阻塞隊(duì)列中，等待被執(zhí)行；
3. 接上面2的條件，且當(dāng)阻塞隊(duì)列滿了之后，繼續(xù)創(chuàng)建thread,從而加速處理阻塞隊(duì)列；
4. 當(dāng)添加任務(wù)大于maximmPoolSize時(shí)，根據(jù)飽和策略決定是否容許繼續(xù)向線程池中添加任務(wù)，默認(rèn)的飽和策略是AbortPolicy（直接丟棄）。

線程池中使用的阻塞隊(duì)列

• ArrayBlockingQueue：基于數(shù)組結(jié)構(gòu)的有界阻塞隊(duì)列，構(gòu)造函數(shù)一定要傳大小，F(xiàn)IFO（先進(jìn)先出）；
• LinkedBlockingQueue：無界，默認(rèn)大小65536（Integer.MAX_VALUE），當(dāng)大量請求任務(wù)時(shí)，容易造成內(nèi)存耗盡。
• SynchronousQueue：同步隊(duì)列，是一個(gè)特殊的BlockingQueue，它沒有容量（這是因?yàn)樵赟ynchronousQueue中，插入將等待另一個(gè)線程的刪除操作，反之亦然）。具體可以參考：《Java SynchronousQueue Examples（譯）》
• PriorityBlockingQueue: 優(yōu)先隊(duì)列，無界。
• DelayedWorkQueue：這個(gè)隊(duì)列接收到任務(wù)時(shí)，首先先入隊(duì)，只有達(dá)到了指定的延時(shí)時(shí)間，才會(huì)執(zhí)行任務(wù)

阻塞隊(duì)列常見的方法如下表所示：

常見四種線程池

• newCachedThreadPool
• newFixedThreadPool
• newSingleThreadExecutor
• newScheduledThreadPool

它們通過Executors以靜態(tài)方法的方式直接調(diào)用，實(shí)質(zhì)上是它們最終調(diào)用的是ThreadPoolExecutor的構(gòu)造方法，也就是本文最前面那段代碼。

注：KeepAliveTime=0的話，表示不等待

《阿里巴巴java開發(fā)手冊》中建議線程池不使用 Executors 去創(chuàng)建，而是通過 ThreadPoolExecutor的方式，這樣的處理方式讓寫的人員更加明確線程池的運(yùn)行規(guī)則，規(guī)避資源耗盡的風(fēng)險(xiǎn)。

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

最新評論