关于 java.util.concurrent.RejectedExecutionExcep

关于 java.util.concurrent.RejectedExecutionException
By @IVANZHANGWB | Published: 2012 年 1 月 5 日
昨天上线一个功能的时候，遇到java.util.concurrent.RejectedExecutionException 这个异常，给系统造成了一定的影响， 记得之前做短信平台项目的时候，有遇到过这个异常，大致知道这个异常的简单意义： 提交的任务被拒绝。
既然又遇到了，就又仔细的了解了一下这个异常发生的大致原因， 目前看来，最主要有2种原因。
第一：
你的线程池ThreadPoolExecutor 显示的shutdown()之后，再向线程池提交任务的时候。 如果你配置的拒绝策略是AbortPolicy的话，这个异常就会抛出来。
第二：
当你设置的任务缓存队列过小的时候，或者说， 你的线程池里面所有的线程都在干活（线程数== maxPoolSize),并且你的任务缓存队列也已经充满了等待的队列， 这个时候，你再向它提交任务，则会抛出这个异常。

下面用例子来说明一下，两种情况：

第一种， 显示关闭掉了线程池
这一点其实理解起来很简单， 比如说，你向一个仓库去存放货物，一开始，仓库管理员把门给你打开了，你放了第一件商品到仓库里面，但是当你放好出去的时候，不小心把仓库的门关掉了， 那么你下次再来存放的时候， 你就会被拒绝掉。
落实到代码就是：

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

06
             public void run() {
07
                 System.out.println("Hello World");
08
             }
09
         });
10
         EXECUTOR.shutdown();
11
     }
如上， 在我们提交第一个任务之后，线程池就被关闭掉了。 那么你再向线程池提交新任务的时候，你就会遇到类似的异常。
为什么会这样？
原因是，在ThreadPoolExecutor内部，存放着当前这个线程池的运行状态。
当你调用shutdown的时候， 线程池会有顺序的将线程池中正在运行的任务给关闭掉。InterruptException这样的异常。

第二种代码如下：

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
         });
13
     }
类似的，当你的线程池中 ，正在执行包括正在等待的线程数有 maxPool + workQueueSize 这个数量的话。 再次向它提交任务，则会遇到这个异常。
比如，上面的线程数： 如果当前线程正在跑的数量 <最大线程， 再加上等待的， 都有我们的业务点吗？

解决办法：
针对第一种，暂时还没找打解决方案。 尽量避免显示调用shutdown方法。
第二种：
可以将线程池的数量调大点（minPoolSize,maxPoolSize,handlerList)这新信息。

评论

2 楼 ksgimi 2013-10-05  

第二种情况，维持线程池的数量不变，增大workQueueSize，是比较好的解决方法。

1 楼 2008tnt 2012-11-26