2019獨(dú)角獸企業(yè)重金招聘Python工程師標(biāo)準(zhǔn)>>>

遇到j(luò)ava.util.concurrent.RejectedExecutionException

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

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

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

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

?????}

如上， 在我們提交第一個(gè)任務(wù)之后，線程池就被關(guān)閉掉了。 那么你再向線程池提交新任務(wù)的時(shí)候，你就會(huì)遇到類似的異常。
為什么會(huì)這樣？
原因是，在ThreadPoolExecutor內(nèi)部，存放著當(dāng)前這個(gè)線程池的運(yùn)行狀態(tài)。
當(dāng)你調(diào)用shutdown的時(shí)候， 線程池會(huì)有順序的將線程池中正在運(yùn)行的任務(wù)給關(guān)閉掉。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

?????}

類似的，當(dāng)你的線程池中 ，正在執(zhí)行包括正在等待的線程數(shù)有 maxPool + workQueueSize 這個(gè)數(shù)量的話。 再次向它提交任務(wù)，則會(huì)遇到這個(gè)異常。
比如，上面的線程數(shù)： 如果當(dāng)前線程正在跑的數(shù)量 <最大線程， 再加上等待的， 都有我們的業(yè)務(wù)點(diǎn)嗎？

解決辦法：
針對第一種，可以再往線程池存放線程之前先判斷線程池是否已經(jīng)關(guān)閉

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 ...");
?}
}

第二種：
可以將線程池的數(shù)量調(diào)大點(diǎn)（minPoolSize,maxPoolSize,handlerList)這新信息。

轉(zhuǎn)載于:https://my.oschina.net/u/1244156/blog/208463

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。