ThreadPoolExecutor
的拒绝策略(RejectedExecutionHandler
)在线程池无法处理新的任务时会被触发。下面介绍 Java 中 ThreadPoolExecutor
提供的几种内置拒绝策略,并展示如何自定义拒绝策略。
1. 内置拒绝策略
AbortPolicy (默认策略)
- 当任务无法被接受时,抛出
RejectedExecutionException
异常。
new ThreadPoolExecutor.AbortPolicy()
- 当任务无法被接受时,抛出
CallerRunsPolicy
- 当任务无法被接受时,调用线程池的线程会执行该任务。这种策略提供了一种“回退”机制,从而降低新任务提交速度。
new ThreadPoolExecutor.CallerRunsPolicy()
DiscardPolicy
- 当任务无法被接受时,直接丢弃任务,不做任何处理。
new ThreadPoolExecutor.DiscardPolicy()
DiscardOldestPolicy
- 当任务无法被接受时,丢弃工作队列中最旧的未处理任务,然后重新尝试提交新任务。
new ThreadPoolExecutor.DiscardOldestPolicy()
2. 自定义拒绝策略
可以通过实现 RejectedExecutionHandler
接口来创建自定义的拒绝策略。例如,记录被拒绝任务的日志或进行其他处理。
import java.util.concurrent.*;
public class