Java多線程中的ThreadPoolExecutor解讀
corePoolSize
線程池中的核心線程數(shù)。當提交一個任務時,線程池創(chuàng)建一個新線程執(zhí)行任務,直到當前線程數(shù)等于corePoolSize;如果當前線程數(shù)為corePoolSize,繼續(xù)提交的任務被保存到阻塞隊列中,等待被執(zhí)行。
maximumPoolSize
線程池中允許的最大線程數(shù)。如果當前阻塞隊列滿了,且繼續(xù)提交任務,則創(chuàng)建新的線程執(zhí)行任務,前提是當前線程數(shù)小于maximumPoolSize。
keepAliveTime
線程空閑時的存活時間。默認情況下,只有當線程池中的線程數(shù)大于corePoolSize時,keepAliveTime才會起作用,如果一個線程空閑的時間達到keepAliveTime,則會終止,直到線程池中的線程數(shù)不超過corePoolSize。但是如果調用了allowCoreThreadTimeOut(boolean)方法,keepAliveTime參數(shù)也會起作用,直到線程池中的線程數(shù)為0。
unit
keepAliveTime參數(shù)的時間單位。
workQueue
任務緩存隊列,用來存放等待執(zhí)行的任務。如果當前線程數(shù)為corePoolSize,繼續(xù)提交的任務就會被保存到任務緩存隊列中,等待被執(zhí)行。 一般來說,這里的BlockingQueue有以下三種選擇:
1.SynchronousQueue:一個不存儲元素的阻塞隊列,每個插入操作必須等到另一個線程調用移除操作,否則插入操作一直處于阻塞狀態(tài)。因此,如果線程池中始終沒有空閑線程(任務提交的平均速度快于被處理的速度),可能出現(xiàn)無限制的線程增長。
2.LinkedBlockingQueue:基于鏈表結構的阻塞隊列,如果不設置初始化容量,其容量為Integer.MAX_VALUE,即為無界隊列。因此,如果線程池中線程數(shù)達到了corePoolSize,且始終沒有空閑線程(任務提交的平均速度快于被處理的速度),任務緩存隊列可能出現(xiàn)無限制的增長。
3.ArrayBlockingQueue:基于數(shù)組結構的有界阻塞隊列,按FIFO排序任務。
threadFactory
線程工廠,創(chuàng)建新線程時使用的線程工廠。
handler
任務拒絕策略,當阻塞隊列滿了,且線程池中的線程數(shù)達到maximumPoolSize,如果繼續(xù)提交任務,就會采取任務拒絕策略處理該任務,線程池提供了4種任務拒絕策略:
1.AbortPolicy:丟棄任務并拋出RejectedExecutionException異常,默認策略;
2.CallerRunsPolicy:由調用execute方法的線程執(zhí)行該任務;
3.DiscardPolicy:丟棄任務,但是不拋出異常;
4.DiscardOldestPolicy:丟棄阻塞隊列最前面的任務,然后重新嘗試執(zhí)行任務(重復此過程)。 當然也可以根據(jù)應用場景實現(xiàn)RejectedExecutionHandler接口,自定義飽和策略,如記錄日志或持久化存儲不能處理的任務。
public static void main(String[] args) {
int corePoolSize = 0;
int maximumPoolSize = 0;
long keepAliveTime = 0;
TimeUnit unit = TimeUnit.SECONDS;
//1.SynchronousQueue:一個不存儲元素的阻塞隊列,每個插入操作必須等到另一個線程調用移除操作,
//否則插入操作一直處于阻塞狀態(tài)。因此,如果線程池中始終沒有空閑線程(任務提交的平均速度快于被處理的速度),
//可能出現(xiàn)無限制的線程增長。
//2.LinkedBlockingQueue:基于鏈表結構的阻塞隊列,如果不設置初始化容量,
//其容量為Integer.MAX_VALUE,即為無界隊列。因此,如果線程池中線程數(shù)達到了corePoolSize,
//且始終沒有空閑線程(任務提交的平均速度快于被處理的速度),任務緩存隊列可能出現(xiàn)無限制的增長。
//3.ArrayBlockingQueue:基于數(shù)組結構的有界阻塞隊列,按FIFO排序任務。
BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<>(100);
ThreadFactory threadFactory = new ThreadFactory() {
@Override
public Thread newThread(Runnable r) {
return new Thread("newThread");
}
};
//1.AbortPolicy:丟棄任務并拋出RejectedExecutionException異常,默認策略;
//2.CallerRunsPolicy:由調用execute方法的線程執(zhí)行該任務;
//3.DiscardPolicy:丟棄任務,但是不拋出異常;
//4.DiscardOldestPolicy:丟棄阻塞隊列最前面的任務,然后重新嘗試執(zhí)行任務(重復此過程)。
RejectedExecutionHandler handler = new RejectedExecutionHandler() {
@Override
public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
}
};
ThreadPoolExecutor threadPoolExecutor =
new ThreadPoolExecutor(
corePoolSize,
maximumPoolSize,
keepAliveTime,
unit,
workQueue);
ThreadPoolExecutor threadPoolExecutor1 =
new ThreadPoolExecutor(
corePoolSize,
maximumPoolSize,
keepAliveTime,
unit,
workQueue,
threadFactory);
ThreadPoolExecutor threadPoolExecutor2 =
new ThreadPoolExecutor(
corePoolSize,
maximumPoolSize,
keepAliveTime,
unit,
workQueue,
handler);
ThreadPoolExecutor threadPoolExecutor3 =
new ThreadPoolExecutor(
corePoolSize,
maximumPoolSize,
keepAliveTime,
unit,
workQueue,
threadFactory,
handler);
}到此這篇關于Java多線程中的ThreadPoolExecutor解讀的文章就介紹到這了,更多相關ThreadPoolExecutor解讀內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
相關文章
Spring Boot優(yōu)化后啟動速度快到飛起技巧示例
這篇文章主要為大家介紹了Spring Boot優(yōu)化后啟動速度快到飛起的技巧示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2022-07-07
Java簡單實現(xiàn)SpringMVC+MyBatis分頁插件
自己最近搭建的一個SpringMVC+Mybatis的框架 屬于無實體類的框架 并實現(xiàn)了Myabtis的自動分頁和總數(shù)查詢 只要傳入分頁參數(shù)便能自動查詢總數(shù)和分頁 總數(shù)封裝在參數(shù)里面執(zhí)行查詢后可以直接從參數(shù)中獲取2015-09-09
Java中SynchronousQueue的底層實現(xiàn)原理剖析
BlockingQueue的實現(xiàn)類中,有一種阻塞隊列比較特殊,就是SynchronousQueue(同步移交隊列),隊列長度為0。本文就來剖析一下SynchronousQueue的底層實現(xiàn)原理,感興趣的可以了解一下2022-11-11
基于創(chuàng)建Web項目運行時出錯的解決方法(必看篇)
下面小編就為大家?guī)硪黄趧?chuàng)建Web項目運行時出錯的解決方法。小編覺得挺不錯的,現(xiàn)在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧2017-08-08
Java?8?的異步編程利器?CompletableFuture的實例詳解
這篇文章主要介紹了Java?8?的異步編程利器?CompletableFuture?詳解,本文通過一個例子給大家介紹下Java?8??CompletableFuture異步編程的相關知識,需要的朋友可以參考下2022-03-03

