java.util.concurrent.RejectedExecutionException

遇到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)這新信息。