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)这新信息。