提交一个新的task到线程池后,此时如果ThreadPool内的所有工作线程都在忙碌时(没有可用的线程去处理该task),并且任务队列也到达界限,这时候就需要用到拒绝策略。
在 java.util.concurrent包下有个RejectedExecutionHandler接口,该接口定义了rejectedExecution方法,用来实现具体的拒绝行为。
-
再往下看,Java预定义了四种拒绝策略:
下面就分析一下这四种拒绝策略有什么不一样:
AbortPolicy
可以看到AbortPolicy其实就是直接抛了个exception,并丢弃该task。
DiscardPolicy
DiscardPolicy什么都没做,静静地丢弃该task
DiscardOldestPolicy
可以看到DiscardOldestPolicy会先通过poll方法,将任务队列的队头,也就是最旧的那个任务remove掉,然后将最新的task放进线程池
CallerRunsPolicy
可以看到,CallerRunsPolicy就是直接调用Runnable的实例方法run去执行该task,说白了就是该task直接由调用者线程来执行
后记
当然,以上四种拒绝策略只是jdk预定义的,我们也可以根据实际情况自定义拒绝策略,只需要实现RejectedExecutionHandler接口即可