ExecutorService为何丢任务

ExecutorService 本身不会“无缘无故”丢任务，所谓“丢任务”通常是因为使用方式或配置不当导致任务未被提交、被拒绝、或被中断。下面按常见原因 → 表现 → 解决办法来说明。

一、 submit / execute 之前线程池已关闭

原因

• 调用了 shutdown() / shutdownNow()
• 之后还在 submit() 任务

表现

• 新任务直接被 拒绝
• 可能抛出 RejectedExecutionException

示例

executor.shutdown();
executor.submit(() -> {}); // 任务丢失 / 异常

解决

• 确保生命周期管理正确
• 或使用 awaitTermination

二、线程池队列满了 + 拒绝策略导致任务消失

原因

• 使用 ArrayBlockingQueue（有界队列）
• 线程数已达 maximumPoolSize
• 拒绝策略是：
  • DiscardPolicy ✅（直接丢）
  • DiscardOldestPolicy

示例

new ThreadPoolExecutor(
    1, 1,
    0L, TimeUnit.SECONDS,
    new ArrayBlockingQueue<>(1),
    new ThreadPoolExecutor.DiscardPolicy()
);

解决

• 用 AbortPolicy（默认，抛异常）
• 或自定义拒绝策略（记录日志 / 持久化）

三、任务抛异常但被“吞掉”

原因

• execute() 中任务抛异常 → 线程死，但不影响池
• submit() 异常被封装在 Future 中
  • 不调用 future.get() → 看起来像“没执行”

示例

executor.submit(() -> {
    throw new RuntimeException("oops");
});
// 不 get，异常完全看不见

解决

• 任务内部 try-catch + 日志
• 或统一 afterExecute 钩子

四、JVM 退出导致任务未执行完

原因

• 主线程结束
• 未 shutdown() + awaitTermination()
• 非 daemon 线程未结束

表现

• 队列里的任务“凭空消失”

解决

executor.shutdown();
executor.awaitTermination(1, TimeUnit.HOURS);

五、任务没真正提交（逻辑问题）

常见错误

• 条件判断错误
• 循环没进去
• 异步方法根本没调用

if (false) {
    executor.submit(task); // 永远不执行
}

解决

• 加日志确认提交点

六、使用了错误线程池

示例

Executors.newSingleThreadExecutor()

• 单个线程挂了 → 后续任务可能阻塞

或：

Executors.newCachedThreadPool()

• 瞬时大量任务 → 线程爆炸

建议

✅ 手动创建 ThreadPoolExecutor，明确参数

七、任务被中断（shutdownNow）

executor.shutdownNow();

• 正在运行的任务收到 InterruptedException
• 队列中任务直接返回，不执行

排查 checklist ✅

1. 是否抛异常？
2. 是否被拒绝？
3. 是否提前 shutdown？
4. 是否 JVM 退出？
5. 是否队列满？
6. 是否用了 Discard 策略？
7. 是否 submit 但没 get？

如果你愿意，可以：

• 贴 线程池创建代码
• 或描述 “丢任务”的具体场景

我可以帮你精准定位是哪一类问题。