ExecutorService怎样避免阻塞

在 Java 中，ExecutorService 本身是为了解耦任务提交与执行、避免直接阻塞调用线程而设计的，但如果使用不当，仍然会出现阻塞、线程耗尽、拒绝任务等问题。下面从常见阻塞场景和避免策略两个角度说明。

一、常见的“阻塞”场景

1. 使用 submit() + Future.get() 无超时

Future<?> f = executor.submit(task);
f.get(); // 可能永久阻塞

✅ 问题：get() 会一直等任务完成。

2. 使用 invokeAll() / invokeAny()

executor.invokeAll(tasks); // 阻塞直到全部完成

✅ 会阻塞调用线程。

3. 线程池队列无限增长

new ThreadPoolExecutor(
    1, 1, 0L, TimeUnit.MILLISECONDS,
    new LinkedBlockingQueue<>() // 无限队列
);

✅ 任务堆积，消费跟不上，导致内存压力或响应变慢。

4. 任务内部阻塞（IO / 锁 / sleep）

executor.execute(() -> {
    socket.read(); // 阻塞线程
});

✅ 线程被占住，线程池“看起来”卡死。

二、避免阻塞的正确姿势

✅ 1. 给 Future.get() 设置超时

try {
    future.get(1, TimeUnit.SECONDS);
} catch (TimeoutException e) {
    future.cancel(true);
}

✅ 2. 使用 CompletableFuture（非阻塞）

CompletableFuture.runAsync(task, executor)
    .thenRun(() -> log.info("done"))
    .exceptionally(ex -> {
        log.error("error", ex);
        return null;
    });

✅ 不阻塞调用线程，支持回调。

✅ 3. 合理设置线程池参数（防止堆积）

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

要点：

• 有界队列
• 合适的拒绝策略
  • CallerRunsPolicy：调用线程执行，天然限流
  • AbortPolicy：快速失败

✅ 4. 异步结果处理，而不是等待

❌ 错误：

executor.submit(this::doWork).get();

✅ 正确：

executor.submit(() -> {
    doWork();
    notifyComplete();
});

✅ 5. IO 密集型任务用独立线程池

ExecutorService ioExecutor =
    Executors.newFixedThreadPool(100);

ExecutorService cpuExecutor =
    Executors.newWorkStealingPool();

✅ 避免 IO 阻塞影响 CPU 任务。

✅ 6. 使用 CompletionService 取已完成任务

CompletionService<String> cs =
    new ExecutorCompletionService<>(executor);

for (Callable<String> task : tasks) {
    cs.submit(task);
}

for (int i = 0; i < tasks.size(); i++) {
    Future<String> f = cs.take(); // 只等最快完成的
}

三、总结原则（重点）

✅ 不要在业务线程里等 Future
✅ 使用有界队列 + 合理拒绝策略
✅ IO / CPU 任务线程池分离
✅ 优先 CompletableFuture / 回调
✅ 所有阻塞操作都要有超时

如果你有具体场景（Web 请求、批量任务、定时任务等），我可以给你更针对性的线程池配置示例。