Java concurrency線程池之線程池原理(四)_動力節(jié)點Java學院整理
更新時間：2017年06月15日 15:03:33 作者：skywang12345
這篇文章主要為大家詳細介紹了Java concurrency線程池之線程池原理，具有一定的參考價值，感興趣的小伙伴們可以參考一下
拒絕策略介紹
線程池的拒絕策略，是指當任務添加到線程池中被拒絕，而采取的處理措施。
當任務添加到線程池中之所以被拒絕，可能是由于：第一，線程池異常關閉。第二，任務數量超過線程池的最大限制。
線程池共包括4種拒絕策略，它們分別是：AbortPolicy, CallerRunsPolicy, DiscardOldestPolicy和DiscardPolicy。
- AbortPolicy -- 當任務添加到線程池中被拒絕時，它將拋出 RejectedExecutionException 異常。
- CallerRunsPolicy -- 當任務添加到線程池中被拒絕時，會在線程池當前正在運行的Thread線程池中處理被拒絕的任務。
- DiscardOldestPolicy -- 當任務添加到線程池中被拒絕時，線程池會放棄等待隊列中最舊的未處理任務，然后將被拒絕的任務添加到等待隊列中。
- DiscardPolicy -- 當任務添加到線程池中被拒絕時，線程池將丟棄被拒絕的任務。
線程池默認的處理策略是AbortPolicy！
拒絕策略對比和示例
下面通過示例，分別演示線程池的4種拒絕策略。
1. DiscardPolicy 示例
import java.lang.reflect.Field;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.ThreadPoolExecutor.DiscardPolicy;
public class DiscardPolicyDemo {
private static final int THREADS_SIZE = 1;
private static final int CAPACITY = 1;
public static void main(String[] args) throws Exception {
// 創(chuàng)建線程池。線程池的"最大池大小"和"核心池大小"都為1(THREADS_SIZE)，"線程池"的阻塞隊列容量為1(CAPACITY)。
ThreadPoolExecutor pool = new ThreadPoolExecutor(THREADS_SIZE, THREADS_SIZE, 0, TimeUnit.SECONDS,
new ArrayBlockingQueue<Runnable>(CAPACITY));
// 設置線程池的拒絕策略為"丟棄"
pool.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardPolicy());
// 新建10個任務，并將它們添加到線程池中。
for (int i = 0; i < 10; i++) {
Runnable myrun = new MyRunnable("task-"+i);
pool.execute(myrun);
}
// 關閉線程池
pool.shutdown();
}
}
class MyRunnable implements Runnable {
private String name;
public MyRunnable(String name) {
this.name = name;
}
@Override
public void run() {
try {
System.out.println(this.name + " is running.");
Thread.sleep(100);
} catch (Exception e) {
e.printStackTrace();
}
}
}
運行結果：
task-0 is running. task-1 is running.
結果說明：線程池pool的"最大池大小"和"核心池大小"都為1(THREADS_SIZE)，這意味著"線程池能同時運行的任務數量最大只能是1"。
線程池pool的阻塞隊列是ArrayBlockingQueue，ArrayBlockingQueue是一個有界的阻塞隊列，ArrayBlockingQueue的容量為1。這也意味著線程池的阻塞隊列只能有一個線程池阻塞等待。
根據""中分析的execute()代碼可知：線程池中共運行了2個任務。第1個任務直接放到Worker中，通過線程去執(zhí)行；第2個任務放到阻塞隊列中等待。其他的任務都被丟棄了！
2. DiscardOldestPolicy 示例
import java.lang.reflect.Field;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.ThreadPoolExecutor.DiscardOldestPolicy;
public class DiscardOldestPolicyDemo {
private static final int THREADS_SIZE = 1;
private static final int CAPACITY = 1;
public static void main(String[] args) throws Exception {
// 創(chuàng)建線程池。線程池的"最大池大小"和"核心池大小"都為1(THREADS_SIZE)，"線程池"的阻塞隊列容量為1(CAPACITY)。
ThreadPoolExecutor pool = new ThreadPoolExecutor(THREADS_SIZE, THREADS_SIZE, 0, TimeUnit.SECONDS,
new ArrayBlockingQueue<Runnable>(CAPACITY));
// 設置線程池的拒絕策略為"DiscardOldestPolicy"
pool.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardOldestPolicy());
// 新建10個任務，并將它們添加到線程池中。
for (int i = 0; i < 10; i++) {
Runnable myrun = new MyRunnable("task-"+i);
pool.execute(myrun);
}
// 關閉線程池
pool.shutdown();
}
}
class MyRunnable implements Runnable {
private String name;
public MyRunnable(String name) {
this.name = name;
}
@Override
public void run() {
try {
System.out.println(this.name + " is running.");
Thread.sleep(200);
} catch (Exception e) {
e.printStackTrace();
}
}
}
運行結果：
task-0 is running. task-9 is running.
結果說明：將"線程池的拒絕策略"由DiscardPolicy修改為DiscardOldestPolicy之后，當有任務添加到線程池被拒絕時，線程池會丟棄阻塞隊列中末尾的任務，然后將被拒絕的任務添加到末尾。
3. AbortPolicy 示例
import java.lang.reflect.Field;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.ThreadPoolExecutor.AbortPolicy;
import java.util.concurrent.RejectedExecutionException;
public class AbortPolicyDemo {
private static final int THREADS_SIZE = 1;
private static final int CAPACITY = 1;
public static void main(String[] args) throws Exception {
// 創(chuàng)建線程池。線程池的"最大池大小"和"核心池大小"都為1(THREADS_SIZE)，"線程池"的阻塞隊列容量為1(CAPACITY)。
ThreadPoolExecutor pool = new ThreadPoolExecutor(THREADS_SIZE, THREADS_SIZE, 0, TimeUnit.SECONDS,
new ArrayBlockingQueue<Runnable>(CAPACITY));
// 設置線程池的拒絕策略為"拋出異常"
pool.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy());
try {
// 新建10個任務，并將它們添加到線程池中。
for (int i = 0; i < 10; i++) {
Runnable myrun = new MyRunnable("task-"+i);
pool.execute(myrun);
}
} catch (RejectedExecutionException e) {
e.printStackTrace();
// 關閉線程池
pool.shutdown();
}
}
}
class MyRunnable implements Runnable {
private String name;
public MyRunnable(String name) {
this.name = name;
}
@Override
public void run() {
try {
System.out.println(this.name + " is running.");
Thread.sleep(200);
} catch (Exception e) {
e.printStackTrace();
}
}
}
(某一次)運行結果：
java.util.concurrent.RejectedExecutionException at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:1774) at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:768) at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:656) at AbortPolicyDemo.main(AbortPolicyDemo.java:27) task-0 is running. task-1 is running.
結果說明：將"線程池的拒絕策略"由DiscardPolicy修改為AbortPolicy之后，當有任務添加到線程池被拒絕時，會拋出RejectedExecutionException。
4. CallerRunsPolicy 示例
import java.lang.reflect.Field;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy;
public class CallerRunsPolicyDemo {
private static final int THREADS_SIZE = 1;
private static final int CAPACITY = 1;
public static void main(String[] args) throws Exception {
// 創(chuàng)建線程池。線程池的"最大池大小"和"核心池大小"都為1(THREADS_SIZE)，"線程池"的阻塞隊列容量為1(CAPACITY)。
ThreadPoolExecutor pool = new ThreadPoolExecutor(THREADS_SIZE, THREADS_SIZE, 0, TimeUnit.SECONDS,
new ArrayBlockingQueue<Runnable>(CAPACITY));
// 設置線程池的拒絕策略為"CallerRunsPolicy"
pool.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
// 新建10個任務，并將它們添加到線程池中。
for (int i = 0; i < 10; i++) {
Runnable myrun = new MyRunnable("task-"+i);
pool.execute(myrun);
}
// 關閉線程池
pool.shutdown();
}
}
class MyRunnable implements Runnable {
private String name;
public MyRunnable(String name) {
this.name = name;
}
@Override
public void run() {
try {
System.out.println(this.name + " is running.");
Thread.sleep(100);
} catch (Exception e) {
e.printStackTrace();
}
}
}
(某一次)運行結果：
task-2 is running. task-3 is running. task-4 is running. task-5 is running. task-6 is running. task-7 is running. task-8 is running. task-9 is running. task-0 is running. task-1 is running.
結果說明：將"線程池的拒絕策略"由DiscardPolicy修改為CallerRunsPolicy之后，當有任務添加到線程池被拒絕時，線程池會將被拒絕的任務添加到"線程池正在運行的線程"中取運行
相關文章
這篇文章主要介紹了Java?各種文件類型轉換的方法,本文通過實例代碼給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2022-03-03
MyBatis-Plus通用枚舉自動關聯(lián)注入的實現
本文主要介紹了MyBatis-Plus通用枚舉自動關聯(lián)注入的實現，解決了繁瑣的配置，讓 mybatis 優(yōu)雅的使用枚舉屬性，感興趣的可以一起來了解一下2021-06-06
這篇文章主要介紹了MybatisPlus中的刪除和邏輯刪除的相關知識，刪除又分為邏輯刪除和物理刪除，那么它們有什么區(qū)別呢？在本文給大家詳細介紹，感興趣的朋友跟隨小編一起看看吧2020-08-08
使用JDBC連接Mysql 8.0.11出現了各種錯誤的解決
這篇文章主要介紹了使用JDBC連接Mysql 8.0.11出現了各種錯誤的解決,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2019-08-08
本文主要介紹了java使用單向鏈表解決數據存儲自定義排序問題，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2022-03-03
本文主要介紹了Java之數組在指定位置插入元素實現，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2023-01-01
Java中的有限狀態(tài)機(設計模式——狀態(tài)模式)
這篇文章主要介紹了Java中的有限狀態(tài)機(設計模式——狀態(tài)模式),具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2023-08-08
這篇文章主要介紹了JDBC連接MySQL數據庫批量插入數據過程詳解,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2019-11-11
這篇文章主要介紹了Redis集群與SSM整合使用方法，非常不錯，具有參考借鑒價值,需要的朋友可以參考下2017-12-12
Java技巧分享之利用RxJava打造可觀測數據RxLiveData
這篇文章主要來和大家分享一個Java技巧，那就是利用RxJava打造可觀測數據RxLiveData，文中的示例代碼講解詳細，感興趣的小伙伴可以了解一下2023-06-06