
线程池的拒绝策略是指,当线程池无法承载更多任务时执行的行为。也就是当线程池的核心线程数、最大线程、任务队列都满的情况下,又来了新的任务时,线程池执行的行为被称之为线程池的拒绝策略。
线程池的执行流程如下:

在 Java 中,线程池内置了以下四种拒绝策略(Rejected Execution Policy)。
1.1 AbortPolicy(中止策略)行为:默认拒绝策略,直接抛出 RejectedExecutionException 异常。特点:强制调用方处理任务被拒绝的情况。适用场景:对任务丢失不敏感的场景。如果对丢失敏感需结合异常捕获机制处理(记录信息并告警)。示例代码:
new ThreadPoolExecutor(..., new ThreadPoolExecutor.AbortPolicy());1.2 CallerRunsPolicy(调用者运行策略)行为:将任务退回给提交任务的线程(即调用 execute() 的线程),由该线程直接执行任务。特点:变相降低任务提交速度,避免线程池过载。适用场景:希望任务最终被处理,且能承受一定延迟(如日志记录)。示例效果:
// 假设线程池已满,主线程提交任务时会直接执行该任务executor.execute(task); // 主线程执行 task1.3 DiscardPolicy(丢弃策略)行为:静默丢弃被拒绝的任务,不抛出异常,也不执行任务。特点:无感知丢弃,可能导致数据丢失。适用场景:允许任务丢失的非关键场景(如实时监控数据采样)。示例代码:
new ThreadPoolExecutor(..., new ThreadPoolExecutor.DiscardPolicy());1.4 DiscardOldestPolicy(丢弃最旧任务策略)行为:丢弃工作队列中等待时间最长的任务(即队列头部的任务),然后重新尝试提交当前任务。特点:优先处理新任务,但可能丢失重要旧任务。适用场景:适合处理时效性较强的任务(如消息推送,新任务优先级更高)。示例代码:
new ThreadPoolExecutor(..., new ThreadPoolExecutor.DiscardOldestPolicy());2.自定义拒绝策略除了以上四种内置拒绝策略之外,程序中还可以通过实现 RejectedExecutionHandler 接口实现自定义策略:
public CustomRejectionPolicy implements RejectedExecutionHandler { @Override public void rejectedExecution(Runnable task, ThreadPoolExecutor executor) { // 自定义逻辑(如记录日志、持久化任务、重试等) System.out.println("Task rejected: " + task); // 保存任务信息 // 通知相关负责人 }}// 使用自定义策略ThreadPoolExecutor executor = new ThreadPoolExecutor( corePoolSize, maxPoolSize, keepAliveTime, unit, workQueue, new CustomRejectionPolicy());小结策略
优点
缺点
适用场景
AbortPolicy
默认拒绝策略,报错提示
需处理异常,增加代码复杂度
任务丢失不敏感的场景
CallerRunsPolicy
任务一定执行
可能阻塞主线程,影响响应速度
非实时任务,允许延迟处理(如日志)
DiscardPolicy
简单高效,无额外开销
数据丢失风险高
可容忍数据丢失的场景(如监控采样)
DiscardOldestPolicy
优先处理新任务
可能丢失重要旧任务
时效性强的任务(如实时消息推送)
CustomRejectionPolicy
灵活
实现复杂
通常用于生产环境,先保存任务信息,再报警提示负责人
本文已收录到我的面试小站 [www.javacn.site](https://www.javacn.site),其中包含的内容有:场景题、并发编程、MySQL、Redis、Spring、Spring MVC、Spring Boot、Spring Cloud、MyBatis、JVM、设计模式、消息队列等模块。