2019獨角獸企業重金招聘Python工程師標準>>>

遇到java.util.concurrent.RejectedExecutionException

目前看來，最主要有2種原因。
第一：
你的線程池ThreadPoolExecutor 顯示的shutdown()之后，再向線程池提交任務的時候。 如果你配置的拒絕策略是AbortPolicy的話，這個異常就會拋出來。
第二：
當你設置的任務緩存隊列過小的時候，或者說， 你的線程池里面所有的線程都在干活（線程數== maxPoolSize),并且你的任務緩存隊列也已經充滿了等待的隊列， 這個時候，你再向它提交任務，則會拋出這個異常。

下面用例子來說明一下，兩種情況：

第一種， 顯示關閉掉了線程池
這一點其實理解起來很簡單， 比如說，你向一個倉庫去存放貨物，一開始，倉庫管理員把門給你打開了，你放了第一件商品到倉庫里面，但是當你放好出去的時候，不小心把倉庫的門關掉了， 那么你下次再來存放的時候， 你就會被拒絕掉。
落實到代碼就是：

ThreadPoolExecutor EXECUTOR = new ThreadPoolExecutor(5, 10, 3000L, TimeUnit.MILLISECONDS,??new LinkedBlockingQueue<Runnable>(4));?

??????for (int i = 0; i < 2; i++) {?

??????????EXECUTOR.execute(new Runnable() {?

??????????????public void run() {?

??????????????????System.out.println("Hello World");?

??????????????}?

??????????});?

??????????EXECUTOR.shutdown();?

??????}

?

01	ThreadPoolExecutor EXECUTOR =?new?ThreadPoolExecutor(5,?10, 3000L, TimeUnit.MILLISECONDS,

02	??????????????????????????????????????????????????????????new?LinkedBlockingQueue<Runnable>(4));

03	?????for?(int?i =?0; i <?2; i++) {

04	?????????EXECUTOR.execute(new?Runnable() {

05	?????????????public?void?run() {

06	?????????????????System.out.println("Hello World");

07	?????????????}

08	?????????});

09	?????????EXECUTOR.shutdown();

10

?????}

如上， 在我們提交第一個任務之后，線程池就被關閉掉了。 那么你再向線程池提交新任務的時候，你就會遇到類似的異常。
為什么會這樣？
原因是，在ThreadPoolExecutor內部，存放著當前這個線程池的運行狀態。
當你調用shutdown的時候， 線程池會有順序的將線程池中正在運行的任務給關閉掉。InterruptException這樣的異常。

第二種代碼如下：

for (int i = 0; i < 15; i++) {?

?????????final int tmpint=i;?

?????????EXECUTOR.execute(new Runnable() {?

?????????????public void run() {?

?????????????????try {?

?????????????????????System.out.println(tmpint+"Hello World");?

?????????????????????Thread.sleep(1000);?

?????????????????} catch (InterruptedException e) {?

?????????????????}?

?????????????}?

?????????});?

?????}

?

01	for?(int?i =?0; i <?15; i++) {

02	?????????final?int?tmpint=i;

03	?????????EXECUTOR.execute(new?Runnable() {

04	?????????????public?void?run() {

05	?????????????????try?{

06	?????????????????????System.out.println(tmpint+"Hello World");

07	?????????????????????Thread.sleep(1000);

08	?????????????????}?catch?(InterruptedException e) {

09	?????????????????}

10	?????????????}

11	?????????});

12

?????}

類似的，當你的線程池中 ，正在執行包括正在等待的線程數有 maxPool + workQueueSize 這個數量的話。 再次向它提交任務，則會遇到這個異常。
比如，上面的線程數： 如果當前線程正在跑的數量 <最大線程， 再加上等待的， 都有我們的業務點嗎？

解決辦法：
針對第一種，可以再往線程池存放線程之前先判斷線程池是否已經關閉

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ExecutorServiceDemo {

?static class MyThread implements Runnable {

??public void run() {
???try {
????Thread.sleep(500);
????// System.out.println("MyThread...");
???} catch (InterruptedException e) {
????e.printStackTrace();
???}
??}
?}

?public static void main(String[] args) {

??ExecutorService pool = Executors.newFixedThreadPool(20);
??
??System.out.println("pool start ...");
??
??for (int i = 0; i < 1000; i++) {
???
???try {

????if(!pool.isShutdown()){
?????
?????pool.execute(new MyThread());
????}

????if (i == 300) {
?????
?????pool.shutdown();
????}
????
???} catch (Exception e) {
????
????e.printStackTrace();
???}
??}
??System.out.println("pool end ...");
?}
}

第二種：
可以將線程池的數量調大點（minPoolSize,maxPoolSize,handlerList)這新信息。

轉載于:https://my.oschina.net/u/1244156/blog/208463

總結

以上是生活随笔為你收集整理的java.util.concurrent.RejectedExecutionException的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。