ExecutorService为何会拒绝任务

ExecutorService 之所以会拒绝任务，本质上是因为：线程池已经没有能力接收新提交的任务了。
在 Java 中，这种行为由 拒绝策略（RejectedExecutionHandler） 来控制。

下面从「为什么会拒绝」和「什么时候会拒绝」两个角度说明。

一、线程池为什么会拒绝任务？

ThreadPoolExecutor 在以下 两种情况同时满足 时会拒绝任务：

1. 线程池已经 SHUTDOWN / STOP

   • 调用了 shutdown() 或 shutdownNow()
   • 不再接受新任务

2. 线程池“满了”

   • 当前线程数 ≥ maximumPoolSize
   • 且 工作队列也已满

此时再提交任务，就会触发 拒绝策略。

二、线程池“满了”的具体条件

线程池运行逻辑简化如下：

提交任务
  ↓
1. 小于 corePoolSize → 创建核心线程
2. 核心线程满 → 放入队列
3. 队列满 → 创建非核心线程（直到 maxPoolSize）
4. 线程数 = maxPoolSize 且队列满 → 拒绝任务

所以拒绝发生在：

线程数已达最大值 + 队列已满 + 还有新任务

三、常见导致拒绝的原因

1. 队列容量太小或用了无界队列的“反面”

new ThreadPoolExecutor(
    2, 4,
    0L, TimeUnit.SECONDS,
    new LinkedBlockingQueue<>(10) // 只能存 10 个
);

• 并发突增
• 任务处理慢
• 队列 + 线程都满 → 拒绝

2. 使用了 SynchronousQueue

new ThreadPoolExecutor(
    2, 4,
    0L, TimeUnit.SECONDS,
    new SynchronousQueue<>()
);

• 队列不存任务
• 没有空闲线程就直接拒绝

3. 任务执行太慢

• sleep
• 网络/IO 阻塞
• 死锁

导致线程长期不释放。

4. 线程池被 shutdown

executor.shutdown();
executor.submit(task); // 拒绝

5. 没有合理监控和扩容

• 固定线程数
• 突发流量
• 无降级 / 限流

四、Java 默认的拒绝策略

五、如何避免拒绝任务？

✅ 1. 合理设置参数

• core / max 线程数
• 队列类型与容量

✅ 2. 使用有界队列 + 合理拒绝策略

new ThreadPoolExecutor(
    10, 50,
    60L, TimeUnit.SECONDS,
    new LinkedBlockingQueue<>(1000),
    new ThreadPoolExecutor.CallerRunsPolicy()
);

✅ 3. 监控线程池

executor.getActiveCount();
executor.getQueue().size();

✅ 4. 上层限流 / 降级

• Sentinel
• 信号量
• 熔断

六、一句话总结

ExecutorService 拒绝任务，是因为线程池已经“既没线程，也没地方排队”，且仍然收到新任务。

如果你愿意，我可以：

• 帮你分析某个具体线程池配置
• 画一张线程池执行流程图
• 给你一个“不会随便拒绝”的实战配置模板