java?線程池如何執(zhí)行策略又拒絕哪些策略
前言：
聊到線程池就一定會聊到線程池的執(zhí)行流程，也就是當有一個任務(wù)進入線程池之后，線程池是如何執(zhí)行的？我們今天就來聊聊這個話題。線程池是如何執(zhí)行的？線程池的拒絕策略有哪些？
線程池執(zhí)行流程
想要真正的了解線程池的執(zhí)行流程，就得先從線程池的執(zhí)行方法 execute() 說起，execute() 實現(xiàn)源碼如下：
public?void?execute(Runnable?command)?{
????if?(command?==?null)
????????throw?new?NullPointerException();
????int?c?=?ctl.get();
????//?當前工作的線程數(shù)小于核心線程數(shù)
????if?(workerCountOf(c)?<?corePoolSize)?{
????????//?創(chuàng)建新的線程執(zhí)行此任務(wù)
????????if?(addWorker(command,?true))
????????????return;
????????c?=?ctl.get();
????}
????//?檢查線程池是否處于運行狀態(tài)，如果是則把任務(wù)添加到隊列
????if?(isRunning(c)?&&?workQueue.offer(command))?{
????????int?recheck?=?ctl.get();
????????//?再次檢線程池是否處于運行狀態(tài)，防止在第一次校驗通過后線程池關(guān)閉
????????//?如果是非運行狀態(tài)，則將剛加入隊列的任務(wù)移除
????????if?(!?isRunning(recheck)?&&?remove(command))
????????????reject(command);
????????//?如果線程池的線程數(shù)為?0?時（當?corePoolSize?設(shè)置為?0?時會發(fā)生）
????????else?if?(workerCountOf(recheck)?==?0)
????????????addWorker(null,?false);?//?新建線程執(zhí)行任務(wù)
????}
????//?核心線程都在忙且隊列都已爆滿，嘗試新啟動一個線程執(zhí)行失敗
????else?if?(!addWorker(command,?false))?
????????//?執(zhí)行拒絕策略
????????reject(command);
}從上述源碼我們可以看出，當任務(wù)來了之后，線程池的執(zhí)行流程是：先判斷當前線程數(shù)是否大于核心線程數(shù)？如果結(jié)果為 false，則新建線程并執(zhí)行任務(wù)；如果結(jié)果為 true，則判斷任務(wù)隊列是否已滿？如果結(jié)果為 false，則把任務(wù)添加到任務(wù)隊列中等待線程執(zhí)行，否則則判斷當前線程數(shù)量是否超過最大線程數(shù)？如果結(jié)果為 false，則新建線程執(zhí)行此任務(wù)，否則將執(zhí)行線程池的拒絕策略，
如下圖所示：
線程池拒絕策略
當任務(wù)過多且線程池的任務(wù)隊列已滿時，此時就會執(zhí)行線程池的拒絕策略，線程池的拒絕策略默認有以下 4 種：
- AbortPolicy：中止策略，線程池會拋出異常并中止執(zhí)行此任務(wù)；
- CallerRunsPolicy：把任務(wù)交給添加此任務(wù)的（main）線程來執(zhí)行；
- DiscardPolicy：忽略此任務(wù)，忽略最新的一個任務(wù)；
- DiscardOldestPolicy：忽略最早的任務(wù)，最先加入隊列的任務(wù)。
默認的拒絕策略為 AbortPolicy 中止策略。
DiscardPolicy拒絕策略
接下來我們以 DiscardPolicy 忽略此任務(wù)，忽略最新的一個任務(wù)為例，演示一下拒絕策略的具體使用，實現(xiàn)代碼如下：
public static void main(String[] args) {
// 任務(wù)的具體方法
Runnable runnable = new Runnable() {
@Override
public void run() {
System.out.println("當前任務(wù)被執(zhí)行,執(zhí)行時間:" + new Date() +
" 執(zhí)行線程:" + Thread.currentThread().getName());
try {
// 等待 1s
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
};
// 創(chuàng)建線程,線程的任務(wù)隊列的長度為 1
ThreadPoolExecutor threadPool = new ThreadPoolExecutor(1, 1,
100, TimeUnit.SECONDS, new LinkedBlockingQueue<>(1),
new ThreadPoolExecutor.DiscardPolicy());
// 添加并執(zhí)行 4 個任務(wù)
threadPool.execute(runnable);
threadPool.execute(runnable);
threadPool.execute(runnable);
threadPool.execute(runnable);
// 線程池執(zhí)行完任務(wù)，關(guān)閉線程池
threadPool.shutdown();
}以上程序的執(zhí)行結(jié)果如下：
從上述執(zhí)行結(jié)果可以看出，給線程池添加了 4 個任務(wù)，而線程池只執(zhí)行了 2 個任務(wù)就結(jié)束了，其他兩個任務(wù)執(zhí)行了拒絕策略 DiscardPolicy 被忽略了，這就是拒絕策略的作用。
AbortPolicy拒絕策略
為了和 DiscardPolicy 拒絕策略對比，我們來演示一下 JDK 默認的拒絕策略 AbortPolicy 中止策略，線程池會拋出異常并中止執(zhí)行此任務(wù)，
示例代碼如下：
public static void main(String[] args) {
// 任務(wù)的具體方法
Runnable runnable = new Runnable() {
@Override
public void run() {
System.out.println("當前任務(wù)被執(zhí)行,執(zhí)行時間:" + new Date() +
" 執(zhí)行線程:" + Thread.currentThread().getName());
try {
// 等待 1s
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
};
// 創(chuàng)建線程,線程的任務(wù)隊列的長度為 1
ThreadPoolExecutor threadPool = new ThreadPoolExecutor(1, 1,
100, TimeUnit.SECONDS, new LinkedBlockingQueue<>(1),
new ThreadPoolExecutor.AbortPolicy()); // 顯式指定拒絕策略，也可以忽略此設(shè)置，它為默認拒絕策略
// 添加并執(zhí)行 4 個任務(wù)
threadPool.execute(runnable);
threadPool.execute(runnable);
threadPool.execute(runnable);
threadPool.execute(runnable);
// 線程池執(zhí)行完任務(wù)，關(guān)閉線程池
threadPool.shutdown();
}以上程序的執(zhí)行結(jié)果如下：
從結(jié)果可以看出，給線程池添加了 4 個任務(wù)，線程池正常執(zhí)行了 2 個任務(wù)，其他兩個任務(wù)執(zhí)行了中止策略，并拋出了拒絕執(zhí)行的異常RejectedExecutionException。
自定義拒絕策略
當然除了 JDK 提供的四種拒絕策略之外，我們還可以實現(xiàn)通過new RejectedExecutionHandler，并重寫 rejectedExecution 方法來實現(xiàn)自定義拒絕策略，
實現(xiàn)代碼如下：
public static void main(String[] args) {
// 任務(wù)的具體方法
Runnable runnable = new Runnable() {
@Override
public void run() {
System.out.println("當前任務(wù)被執(zhí)行,執(zhí)行時間:" + new Date() +
" 執(zhí)行線程:" + Thread.currentThread().getName());
try {
// 等待 1s
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
};
// 創(chuàng)建線程,線程的任務(wù)隊列的長度為 1
ThreadPoolExecutor threadPool = new ThreadPoolExecutor(1, 1,
100, TimeUnit.SECONDS, new LinkedBlockingQueue<>(1),
new RejectedExecutionHandler() {
@Override
public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
// 執(zhí)行自定義拒絕策略的相關(guān)操作
System.out.println("我是自定義拒絕策略~");
}
});
// 添加并執(zhí)行 4 個任務(wù)
threadPool.execute(runnable);
threadPool.execute(runnable);
threadPool.execute(runnable);
threadPool.execute(runnable);
}以上程序的執(zhí)行結(jié)果如下：
總結(jié)
線程池的執(zhí)行流程有 3 個重要的判斷點（判斷順序依次往后）：判斷當前線程數(shù)和核心線程數(shù)、判斷當前任務(wù)隊列是否已滿、判斷當前線程數(shù)是否已達到最大線程數(shù)。如果經(jīng)過以上 3 個判斷，得到的結(jié)果都會 true，則會執(zhí)行線程池的拒絕策略。JDK 提供了 4 種拒絕策略，我們還可以通過 new RejectedExecutionHandler 并重寫 rejectedExecution 方法來實現(xiàn)自定義拒絕策略。
到此這篇關(guān)于java 線程池如何執(zhí)行策略又拒絕哪些策略的文章就介紹到這了,更多相關(guān)Java 線程池策略內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
這篇文章主要介紹了spring整合hibernate的方法，本文給大家介紹的非常詳細，具有一定的參考借鑒價值,需要的朋友可以參考下2020-02-02
這篇文章主要介紹了springboot測試類注解，本文給大家介紹的非常詳細，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下2022-07-07
本篇文章主要介紹了java shiro實現(xiàn)退出登陸清空緩存，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-02-02
SpringBoot+Quartz+數(shù)據(jù)庫存儲的完美集合
這篇文章主要介紹了SpringBoot+Quartz+數(shù)據(jù)庫存儲的示例代碼，本文通過實例代碼圖文相結(jié)合給大家介紹的非常詳細，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下2022-02-02
解決IDEA2021版compiler.automake.allow.when.app.running不存在的問題
很多文章介紹IntelliJ IDEA開啟熱部署功能都會寫到在IntelliJ IDEA中的注冊表中開啟compiler.automake.allow.when.app.running選項，此選項在IntelliJ IDEA 2021.2之后的版本遷移到高級設(shè)置中，下面看下設(shè)置方法2021-09-09
Springboot?手動分頁查詢分批批量插入數(shù)據(jù)的實現(xiàn)流程
這篇文章主要介紹了Springboot?手動分頁查詢分批批量插入數(shù)據(jù)的實現(xiàn)流程,本文通過實例代碼給大家介紹的非常詳細，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下2022-07-07
Spring mvc整合tiles框架的簡單入門教程（maven）
這篇文章主要給大家介紹了關(guān)于Spring mvc整合tiles框架的簡單入門教程（maven），文中通過示例代碼介紹的非常詳細，對大家具有一定的參考學(xué)習(xí)價值，需要的朋友可以參考借鑒，下面來一起看看詳細的介紹吧。2017-12-12
Java數(shù)據(jù)結(jié)構(gòu)專題解析之棧和隊列的實現(xiàn)
從數(shù)據(jù)結(jié)構(gòu)的定義看，棧和隊列也是一種線性表。其不同之處在于棧和隊列的相關(guān)運算具有特殊性，只是線性表相關(guān)運算的一個子集。更準確的說，一般線性表的插入、刪除運算不受限制，而棧和隊列上的插入刪除運算均受某種特殊限制。因此，棧和隊列也稱作操作受限的線性表2021-10-10
這篇文章主要介紹了Java并發(fā)編程之volatile變量介紹,volatile提供了弱同步機制,用來確保將變量更新通知到其它線程,需要的朋友可以參考下2015-04-04
這篇文章主要介紹了Java基于Swing實現(xiàn)的打獵射擊游戲代碼,包含完整的游戲事件處理與邏輯流程控制,具有不錯的參考借鑒價值,需要的朋友可以參考下2014-11-11