线程池拒绝策略源码小析

  • 提交一个新的task到线程池后,此时如果ThreadPool内的所有工作线程都在忙碌时(没有可用的线程去处理该task),并且任务队列也到达界限,这时候就需要用到拒绝策略。

  • 在 java.util.concurrent包下有个RejectedExecutionHandler接口,该接口定义了rejectedExecution方法,用来实现具体的拒绝行为。

image.png
  • 再往下看,Java预定义了四种拒绝策略:


    image.png

下面就分析一下这四种拒绝策略有什么不一样:

AbortPolicy

image.png

可以看到AbortPolicy其实就是直接抛了个exception,并丢弃该task。

DiscardPolicy

image.png

DiscardPolicy什么都没做,静静地丢弃该task

DiscardOldestPolicy

image.png

可以看到DiscardOldestPolicy会先通过poll方法,将任务队列的队头,也就是最旧的那个任务remove掉,然后将最新的task放进线程池

CallerRunsPolicy

image.png

可以看到,CallerRunsPolicy就是直接调用Runnable的实例方法run去执行该task,说白了就是该task直接由调用者线程来执行

后记

当然,以上四种拒绝策略只是jdk预定义的,我们也可以根据实际情况自定义拒绝策略,只需要实现RejectedExecutionHandler接口即可

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容