拒绝策略选择取决于任务不可承受的后果:abortpolicy用于强一致性任务,抛异常暴露问题;callerrunspolicy让调用方减速反压;discardpolicy静默丢弃低价值任务;discardoldestpolicy优先保留新任务,适用于时效敏感场景。

选对拒绝策略,关键不是看“它能做什么”,而是看“你的任务不能承受什么”。它只在四个条件同时满足时才生效:线程池运行中、核心线程已满、工作队列已满、最大线程数已达上限。策略不是补救措施,而是你提前设定的资源边界守门人。
AbortPolicy:要失败得清楚,就选它
默认策略,直接抛 RejectedExecutionException。它不掩盖问题,把压力立刻暴露给调用方。
- 适合支付确认、库存扣减、订单落库等强一致性、不可丢、不可延的任务
- 必须配合 try-catch,且建议在 catch 中记录任务类型、线程池当前状态(活跃线程数、队列大小、池大小)并触发告警
- 不适合上游无异常处理能力的场景,否则可能引发级联中断
CallerRunsPolicy:想让提交方减速,就选它
被拒任务由调用线程(比如 Tomcat 的请求线程)同步执行。这不是重试,是把压力“还回去”,天然形成反压。
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
- 适合日志上报、异步通知、缓存预热等可延迟但不可丢的任务
- 能有效抑制突发流量,防止下游线程池持续过载
- 慎用于高吞吐接口或实时性敏感链路——主线程阻塞会拖慢整个请求响应
DiscardPolicy:允许丢,且不想花任何成本,就选它
静默丢弃,不抛异常、不打日志、不执行任何逻辑。开销最低。
- 适合心跳上报、埋点统计、采样监控等丢失无影响、价值极低的任务
- 生产环境单独使用风险高,务必搭配监控看板观察拒绝率趋势;一旦持续升高,说明系统已长期超负荷
- 常与 Sentinel 或 Resilience4j 等限流组件组合使用,实现“先限流、再丢弃”的双保险
DiscardOldestPolicy:新数据比旧数据重要,就选它
尝试移除队列中最老的任务,腾出空间后重新提交当前任务。仅对支持 poll() 的队列(如 ArrayBlockingQueue、LinkedBlockingQueue)有效。
- 适合实时行情推送、设备状态轮询、消息拉取等时效性优先、旧数据已失效的场景
- 注意:若队列为空或移除失败,仍会按默认逻辑拒绝;移除操作本身有轻微并发开销
- 不适用于需要严格 FIFO 或依赖任务顺序的业务
Java免费学习笔记:立即使用
解锁 Java 大师之旅:从入门到精通的终极指南










