关于 java.util.concurrent.RejectedExecutionException
(2012-07-03 22:36:38)
标签:
rejectedexecutionit |
分类: java分布式、并发 |
遇到java.util.concurrent.RejectedExecutionExcepti
目前看来,最主要有2种原因。
第一:
你的线程池ThreadPoolExecutor 显示的shutdown()之后,再向线程池提交任务的时候。
如果你配置的拒绝策略是AbortPolicy的话,这个异常就会抛出来。
第二:
当你设置的任务缓存队列过小的时候,或者说, 你的线程池里面所有的线程都在干活(线程数==
maxPoolSize),并且你的任务缓存队列也已经充满了等待的队列, 这个时候,你再向它提交任务,则会抛出这个异常。
下面用例子来说明一下,两种情况:
第一种, 显示关闭掉了线程池
这一点其实理解起来很简单,
比如说,你向一个仓库去存放货物,一开始,仓库管理员把门给你打开了,你放了第一件商品到仓库里面,但是当你放好出去的时候,不小心把仓库的门关掉了,
那么你下次再来存放的时候, 你就会被拒绝掉。
落实到代码就是:
ThreadPoolExecutor
EXECUTOR = new ThreadPoolExecutor(5, 10, 3000L,
TimeUnit.MILLISECONDS,
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++) {
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 {
}
第二种:
可以将线程池的数量调大点(minPoolSize,maxPoolSize,handlerList)这新信息。