線程池技術在并發(fā)時經常會使用到，java中的線程池的使用是通過調用ThreadPoolExecutor來實現的。ThreadPoolExecutor提供了四個構造函數,最后都會歸結于下面這個構造方法：

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

這些參數的意義如下：

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

ThreadPoolExecutor工作流程

流程圖如下：

大致過程陳述為：

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

線程池中使用的阻塞隊列

• ArrayBlockingQueue：基于數組結構的有界阻塞隊列，構造函數一定要傳大小，FIFO（先進先出）；
• LinkedBlockingQueue：無界，默認大小65536（Integer.MAX_VALUE），當大量請求任務時，容易造成內存耗盡。
• SynchronousQueue：同步隊列，是一個特殊的BlockingQueue，它沒有容量（這是因為在SynchronousQueue中，插入將等待另一個線程的刪除操作，反之亦然）。具體可以參考：《Java SynchronousQueue Examples（譯）》
• PriorityBlockingQueue: 優(yōu)先隊列，無界。
• DelayedWorkQueue：這個隊列接收到任務時，首先先入隊，只有達到了指定的延時時間，才會執(zhí)行任務

阻塞隊列常見的方法如下表所示：

常見四種線程池

• newCachedThreadPool
• newFixedThreadPool
• newSingleThreadExecutor
• newScheduledThreadPool

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

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

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

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。

最新評論