当任务队列满且线程达上限时，需通过拒绝策略处理新任务。Java 提供 RejectedExecutionHandler 接口，其 rejectedExecution 方法在任务被拒时触发。内置四种策略：AbortPolicy 抛异常，适用于高一致性场景；DiscardPolicy 静默丢弃，适合可容忍丢失的场景；DiscardOldestPolicy 丢弃最老任务并重试，提升任务处理量；CallerRunsPolicy 由调用线程执行任务，实现限流降级。可根据业务需求自定义策略，如记录日志、写入备用队列等，增强系统容错性与可观测性。结合监控与动态调整机制可进一步提升稳定性。
当线程池中的任务队列已满且线程数达到最大限制时，新提交的任务无法被处理，此时就需要定义拒绝策略。Java 提供了 RejectedExecutionHandler 接口来实现自定义或使用内置的拒绝策略。合理设计拒绝策略能提升系统的稳定性与容错能力。
理解 RejectedExecutionHandler 接口
该接口只有一个方法：void rejectedExecution(Runnable r, ThreadPoolExecutor executor)。当任务被拒绝时，该方法会被调用。你可以在此方法中定义具体的处理逻辑。
Java 内置了四种常见策略：
- ThreadPoolExecutor.AbortPolicy：默认策略，抛出 RejectedExecutionException 异常。
- ThreadPoolExecutor.DiscardPolicy：静默丢弃新任务，不抛异常。
- ThreadPoolExecutor.DiscardOldestPolicy：丢弃队列中最老的任务（即队首任务），然后尝试重新提交当前任务。
- ThreadPoolExecutor.CallerRunsPolicy：由提交任务的线程直接执行任务，起到“限流”作用。
根据业务场景选择合适的策略
不同业务对任务丢失的容忍度不同，应据此选择策略：
立即学习“Java免费学习笔记（深入）”；
- 对数据完整性要求高的系统（如支付、订单），建议使用 AbortPolicy 或自定义策略记录日志并告警。
- 允许少量任务丢失的场景（如日志采集），可采用 DiscardPolicy。
- 希望尽量处理更多任务的场景，DiscardOldestPolicy 更合适。
- 需要平滑降级防止雪崩时，CallerRunsPolicy 可让主线程参与执行，减缓请求流入速度。
自定义拒绝策略增强控制力
通过实现 RejectedExecutionHandler 接口，可以加入日志记录、监控上报、重试机制等逻辑。
示例：记录日志并尝试写入备用队列
public class LoggingRejectHandler implements RejectedExecutionHandler {
private static final Logger log = LoggerFactory.getLogger(LoggingRejectHandler.class);
private final BlockingQueue<Runnable> backupQueue;
public LoggingRejectHandler(BlockingQueue<Runnable> backupQueue) {
this.backupQueue = backupQueue;
}
@Override
public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
log.warn("Task rejected: {}, executor={}", r, executor);
// 尝试放入备用队列（如持久化队列）
if (!backupQueue.offer(r)) {
log.error("Backup queue is full, task dropped: {}", r);
}
}
}
这种做法适用于可接受延迟但不能丢失任务的系统，比如消息推送服务。
结合监控和动态调整提升健壮性
在生产环境中，拒绝任务往往意味着系统压力过大。建议：
- 在拒绝策略中增加指标统计（如 Prometheus 计数器），便于监控报警。
- 配合动态线程池组件（如 Alibaba Sentinel 或自研框架），根据负载情况调整核心参数。
- 定期分析拒绝日志，优化线程池大小或队列容量。
基本上就这些。关键是根据业务特性权衡性能与可靠性，选择或定制最合适的拒绝方式。
