线程池的拒绝策略

超、凢脫俗 2022-12-31 07:30 113阅读 0赞

# [线程池的拒绝策略 ][Link 1] #

在创建线程池时我们可以指定自己的拒绝策略，如下

![d9f2b7988f5202a7e8b91bc5ff20e07f.png][]

## 什么时候会触发拒绝策略 ##

1.  当我们调用 shutdown 等方法关闭线程池后，如果再向线程池内提交任务，就会遭到拒绝。
2.  线程池没有空闲线程（线程池的线程达到了最大线程数，并且都在执行任务）并且队列已经满了，不能在存放任务了。

## 拒绝策略 ##

ThreadPoolExecutor 类有4 种默认的拒绝策略

### AbortPolicy ###

这种拒绝策略在拒绝任务时，会直接抛出一个类型为 RejectedExecutionException 的 RuntimeException，让你感知到任务被拒绝了，于是你便可以根据业务逻辑选择重试或者放弃提交等策略。

### DiscardPolicy ###

当有新任务被提交后直接被丢弃掉，也不会给你任何的通知，相对而言存在一定的风险，因为我们提交的时候根本不知道这个任务会被丢弃，可能造成数据丢失。

### DiscardOldestPolicy ###

丢弃任务队列中的头结点，通常是存活时间最长的任务，它也存在一定的数据丢失风险。

### CallerRunsPolicy ###

第四种拒绝策略是 ，相对而言它就比较完善了，当有新任务提交后，如果线程池没被关闭且没有能力执行，则把这个任务交于提交任务的线程执行，也就是谁提交任务，谁就负责执行任务。这样做主要有两点好处。

第一点新提交的任务不会被丢弃，这样也就不会造成业务损失。 第二点好处是，由于谁提交任务谁就要负责执行任务，这样提交任务的线程就得负责执行任务，而执行任务又是比较耗时的，在这段期间，提交任务的线程被占用，也就不会再提交新的任务，减缓了任务提交的速度，相当于是一个负反馈。在此期间，线程池中的线程也可以充分利用这段时间来执行掉一部分任务，腾出一定的空间，相当于是给了线程池一定的缓冲期。

## 自定义拒绝策略 ##

实现 RejectedExecutionHandler 接口来实现自己的拒绝策略，如代码所示：

![709f5237bd14a309d2e9ff4c14cdb5a4.png][]

分类: [java并发][java]

[Link 1]: https://www.cnblogs.com/zz-ksw/p/12831249.html
[d9f2b7988f5202a7e8b91bc5ff20e07f.png]: /images/20221120/356e9753f0034f68b2e03949c88d1ced.png
[709f5237bd14a309d2e9ff4c14cdb5a4.png]: /images/20221120/e849137b8c174650a03821492fd4cbb6.png
[java]: https://www.cnblogs.com/zz-ksw/category/1757672.html