线程池拒绝策略实现

线程池拒绝策略实现：如何优雅应对任务洪峰

作为一名Java程序员，面试中被问到线程池的拒绝策略绝对是高频题。当线程池的工作队列满了且线程数达到最大值时，线程池拒绝策略就登场了。理解并实现线程池拒绝策略，是构建健壮并发系统的关键一步。今天就带大家拆解这个面试必考点。

---

🛡 线程池拒绝策略的核心逻辑

当线程池处于SHUTDOWN状态或工作队列饱和且线程数达最大值时，新提交的任务就会触发拒绝策略。Java在ThreadPoolExecutor类中提供了四种内置实现，都实现了RejectedExecutionHandler接口：

1. AbortPolicy（默认策略）
   直接抛出RejectedExecutionException异常，粗暴但明确。适用于需要严格保证任务不丢失的场景。
   

2. CallerRunsPolicy
   “让提交任务的线程自己干！” 主线程直接执行被拒绝的任务。相当于用调用线程作为备用线程，能天然限制任务提交速度。

3. DiscardPolicy
   直接丢弃新任务，不抛异常也不执行。就像什么都没发生过，适用于可容忍丢任务的场景（如日志统计）。

4. DiscardOldestPolicy
   丢弃队列里等待最久的任务（队首任务），再尝试重新提交当前任务。适合时效性敏感但允许部分旧任务丢失的场景。

---

🔧 如何自定义线程池拒绝策略

面试官常问：“如果内置策略不满足需求怎么办？” 很简单，实现RejectedExecutionHandler接口即可：

public class CustomRejectHandler implements RejectedExecutionHandler {
    @Override
    public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
        // 1. 记录日志并告警
        log.warn("Task rejected: {}", r);
        // 2. 持久化到数据库或消息队列
        saveToRedis(r);
        // 3. 返回特定错误码给调用方
        if (r instanceof Callable) {
            ((Callable<?>) r).setResult(ErrorCodes.THREADPOOL_BUSY);
        }
    }
}

📌 关键实践要点：

• 结合executor.getQueue().size()判断队列深度
• 通过executor.isShutdown()避免在关闭后接受任务
• 异步持久化时需防止二次拒绝（用独立线程池处理）

---

⚡ 生产环境中的线程池拒绝策略选择

根据业务容忍度做决策：

| 策略类型 | 适用场景 | 风险点 | |------------------|-----------------------------------|-----------------------| | AbortPolicy | 支付、订单等核心业务 | 可能中断主流程 | | CallerRuns | 查询类服务（天然限流） | 阻塞调用线程 | | DiscardOldest| 实时数据上报（优先保障最新数据） | 可能丢失关键历史数据 | | 自定义策略 | 需降级/持久化的高并发场景 | 实现复杂度较高 |

📌2025年精选面试宝典已更新：
🔹 Java面试宝典下载（含50+线程池实战案例）

---

🚀 面试答题技巧

当被要求手写拒绝策略时，建议这样表述：

“在我们电商促销系统里，采用的自定义策略分三层处理：

1. 首先检查线程池是否已关闭，避免无效提交
2. 将任务信息压缩后存入Redis死信队列
3. 启动备用线程每5分钟尝试重试队列任务 这样既保证核心链路不阻塞，又能实现任务最终执行。”

---

最后再提一嘴，如果你需要开通面试鸭会员，通过 面试鸭返利网 找我可返25元！用省下来的钱买杯咖啡☕，继续攻克技术难关更香~

(通过返利网订购会员更划算哦)

理解线程池拒绝策略的实现逻辑，不仅能让你在面试中游刃有余，更能为实际高并发场景提供关键保护机制。记住：没有万能的策略，只有最适合业务的解决方案。