ExecutorCompletionService是Java中用于实现任务完成即处理的工具，它通过结合线程池与阻塞队列，将任务执行与结果获取解耦；提交任务后，可使用take()或poll()方法从队列中获取最先完成的任务结果，无需按提交顺序等待；适用于任务耗时差异大、需快速响应完成结果的场景，如爬虫解析、多源搜索等；相比invokeAll，它提升处理效率，支持非阻塞和超时获取结果，使异步任务结果收集更灵活高效。
在Java并发编程中，当需要提交多个任务并逐个获取结果时，ExecutorCompletionService 是一个非常实用的工具。它结合了 ExecutorService 和 BlockingQueue 的能力，能够在线程任务完成时立即获取结果，而不需要按提交顺序等待。这对于处理耗时不确定的任务尤其有效。
什么是ExecutorCompletionService？
ExecutorCompletionService 是 java.util.concurrent 包中的一个辅助类，用于将执行服务（Executor）与结果队列解耦。它内部维护一个 BlockingQueue<future>></future>，每当一个任务完成，其 Future 结果就会被放入队列中，开发者可以通过 take() 或 poll() 方法获取已完成的任务结果。
相比直接使用 ExecutorService.invokeAll() 等待所有任务完成，CompletionService 支持“谁先完成就处理谁”的模式，提升响应效率。
基本使用步骤
以下是使用 ExecutorCompletionService 的典型流程：
立即学习“Java免费学习笔记（深入）”；
- 创建线程池（ExecutorService）
- 构建 ExecutorCompletionService 实例，传入线程池
- 提交多个 Callable 任务
- 循环调用
take()获取已完成任务的结果 - 处理每个结果，直到所有任务完成
示例代码：
import java.util.concurrent.*;
<p>public class CompletionServiceDemo {
public static void main(String[] args) throws InterruptedException, ExecutionException {
// 创建线程池
ExecutorService executor = Executors.newFixedThreadPool(4);
// 创建 CompletionService
ExecutorCompletionService<String> completionService =
new ExecutorCompletionService<>(executor);</p><pre class='brush:java;toolbar:false;'> // 提交5个任务
for (int i = 0; i < 5; i++) {
final int taskId = i;
completionService.submit(() -> {
// 模拟不同耗时
Thread.sleep((5 - taskId) * 1000L);
return "任务" + taskId + "完成";
});
}
// 获取结果：先完成的先处理
for (int i = 0; i < 5; i++) {
String result = completionService.take().get(); // take() 阻塞直到有结果
System.out.println("接收到结果: " + result);
}
executor.shutdown();
}}
在调试 Java 后端 API 故障时使用此技能，尤其适用于以下任务：分析日志、跨 Controller、Service 和 Mapper 层追踪请求、定位异常根因、检查 SQL 执行或参数流转，以及生成简洁的诊断结论与修复方案。
输出可能为：
接收到结果: 任务4完成 接收到结果: 任务3完成 接收到结果: 任务2完成 ...
可以看到，耗时最短的任务最先返回结果。
适用场景与优势
适用场景：
- 多个独立任务执行时间差异大，希望尽快处理已完成任务
- 爬虫系统中下载多个网页，哪个先下完就先解析哪个
- 搜索服务中查询多个数据源，返回第一个可用结果（结合
poll超时机制） - 需要实现“最快响应”策略的业务逻辑
核心优势：
- 结果获取顺序不依赖任务提交顺序
- 避免长时间等待慢任务
- 简化异步结果收集逻辑
- 与阻塞队列结合自然，易于控制消费节奏
进阶技巧：带超时的结果获取
使用 poll(long timeout, TimeUnit) 可以设置等待结果的超时时间，适用于对响应时间敏感的场景。
// 尝试在1秒内获取结果，否则继续其他逻辑
Future<String> future = completionService.poll(1, TimeUnit.SECONDS);
if (future != null) {
String result = future.get();
System.out.println("及时获取到结果: " + result);
} else {
System.out.println("暂无完成任务");
}
这个特性可用于实现阶段性结果处理或非阻塞轮询。
基本上就这些。合理使用 ExecutorCompletionService 能让并发任务的结果处理更高效、更灵活，特别适合关注“完成即处理”的业务需求。关键是理解它背后的队列驱动机制，避免误以为结果会按提交顺序返回。
