`
刘小小尘
  • 浏览: 62302 次
  • 性别: Icon_minigender_1
  • 来自: 上海
社区版块
存档分类
最新评论

关于 java.util.concurrent.RejectedExecutionExce

 
阅读更多

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

下面用例子来说明一下,两种情况:

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

01 ThreadPoolExecutor EXECUTOR =newThreadPoolExecutor(5,10, 3000L, TimeUnit.MILLISECONDS,
02 newLinkedBlockingQueue<Runnable>(4));
03 for(inti =0; i <2; i++) {
04 EXECUTOR.execute(newRunnable() {
05
06 publicvoidrun() {
07 System.out.println("Hello World");
08 }
09 });
10 EXECUTOR.shutdown();
11 }

如上, 在我们提交第一个任务之后,线程池就被关闭掉了。 那么你再向线程池提交新任务的时候,你就会遇到类似的异常。
为什么会这样?
原因是,在ThreadPoolExecutor内部,存放着当前这个线程池的运行状态。
当你调用shutdown的时候, 线程池会有顺序的将线程池中正在运行的任务给关闭掉。InterruptException这样的异常。

第二种代码如下:

01 for(inti =0; i <15; i++) {
02 finalinttmpint=i;
03 EXECUTOR.execute(newRunnable() {
04 publicvoidrun() {
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)这新信息。

分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics