Java中的线程池拒绝策略详解

一、拒绝策略的背景与作用

当线程池的任务缓存队列已满且线程数达到最大线程数时，新提交的任务会触发拒绝策略（Rejection Policy）。拒绝策略是线程池保护自身资源不被耗尽的关键机制，确保系统在过载时仍能可控运行。

二、线程池的触发条件

拒绝策略的触发需同时满足以下条件：

1. 线程池状态为RUNNING（非RUNNING状态会直接拒绝新任务）。
2. 工作线程数 ≥ 核心线程数，且任务队列已满。
3. 工作线程数 = 最大线程数，无法创建新线程。

此时，新任务会调用RejectedExecutionHandler处理。

三、四种内置拒绝策略详解

Java提供了四种默认策略（均实现RejectedExecutionHandler接口）：

1. AbortPolicy（默认策略）

• 行为：直接抛出RejectedExecutionException异常，中断提交过程。
• 适用场景：需要明确感知任务被拒绝的严格场景，如关键业务系统。
• 示例代码逻辑：

  public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {  
      throw new RejectedExecutionException("Task " + r + " rejected");  
  }  
  

2. CallerRunsPolicy

• 行为：将任务回退给提交任务的线程直接执行（相当于让调用线程临时充当工作线程）。
• 作用：降低新任务提交速度，缓解线程池压力，同时保证任务不丢失。
• 风险：若提交线程被长时间占用，可能影响整体响应效率。

3. DiscardPolicy

• 行为：静默丢弃新任务，不抛异常也不执行。
• 适用场景：对任务丢失不敏感的场景（如日志统计）。
• 注意：需谨慎使用，可能因任务丢失导致业务逻辑异常。

4. DiscardOldestPolicy

• 行为：丢弃队列中最旧的任务（即队列头部的任务），然后重试提交新任务。
• 风险：可能丢弃重要任务，需确保旧任务可丢弃。
• 示例逻辑：

  public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {  
      if (!e.isShutdown()) {  
          e.getQueue().poll(); // 丢弃队首任务  
          e.execute(r);        // 重试提交新任务  
      }  
  }  
  

四、自定义拒绝策略的实现

通过实现RejectedExecutionHandler接口，可灵活定制策略，例如：

1. 持久化策略：将拒绝的任务存入数据库或消息队列，待线程池空闲时重放。
2. 降级策略：触发业务降级逻辑，如返回默认结果。
3. 混合策略：结合多种策略，如先尝试CallerRunsPolicy，失败后持久化。

示例代码：

public class CustomRejectionHandler implements RejectedExecutionHandler {  
    @Override  
    public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {  
        // 记录任务信息并异步重试  
        System.out.println("Task rejected, logging to retry queue: " + r);  
        // 模拟重试逻辑  
        new Thread(r).start();  
    }  
}  

五、配置拒绝策略的实践建议

1. 核心线程数：根据业务特性设置，避免频繁触发拒绝策略。
2. 队列选择：
   • 有界队列（如ArrayBlockingQueue）需明确队列容量，防止内存溢出。
   • 无界队列（如LinkedBlockingQueue）需警惕任务堆积导致内存泄漏。
3. 监控与告警：对拒绝任务数量进行监控，及时调整线程池参数。

六、总结

拒绝策略是线程池的安全阀，需根据业务容忍度选择：

• 严格场景：用AbortPolicy明确失败。
• 柔性场景：用CallerRunsPolicy或自定义策略保证任务执行。
• 可丢弃场景：用DiscardPolicy系列策略。

通过合理配置，可在资源控制与任务执行之间取得平衡。