ExecutorCompletionService能按任务完成顺序获取结果，适用于多数据源查询等需快速响应的场景；通过将Executor与阻塞队列结合，提交任务后调用take().get()即可获取首个完成任务的结果，避免轮询Future的开销；示例中任务B最快完成，即使非首提交也能优先返回；建议合理配置线程池、及时关闭资源，并在获取结果后取消剩余任务以提升效率。
在Java并发编程中，有时我们并不关心所有任务的执行顺序，而是希望尽快拿到最先完成的任务结果，比如在多个数据源查询中取最快返回的结果。这种场景下，ExecutorCompletionService 是一个非常实用的工具。它能帮助我们高效获取最先完成的异步任务，提升系统响应速度。
什么是ExecutorCompletionService？
ExecutorCompletionService 是 Java 提供的一个包装类，它将 Executor 和一个阻塞队列结合起来，用于提交任务并按任务完成的先后顺序获取结果。与直接使用 ExecutorService.submit() 返回 Future 列表再轮询不同，CompletionService 内部维护了一个 BlockingQueue<future>></future>，每有一个任务完成，其 Future 就会被放入队列，从而实现“谁先完成就先处理谁”。
它的核心优势是：避免了手动遍历 Future 列表调用 get() 的阻塞等待，提升了任务结果处理的实时性。
如何使用CompletionService获取最先完成的任务
以下是一个典型使用示例，展示如何从多个并发任务中获取第一个完成的结果：
立即学习“Java免费学习笔记（深入）”；
当用户要求为 Java 代码添加注释、修改注释、审查注释、整理注释格式，或要求按照代码注释规范处理 Java 文件时，使用本技能。本技能用于统一生成和维护 Java 类注释模板、按 Git 对比 release 判断版本号、补充每行代码上方中文块注释、调整注释空行规则，并保持 Java 文件 UTF-8 无 BOM 编码。典型触发场景包括：补充类注释、更新 @version、检查 @author 来源、整理行尾注释、把注释放到代码上一行、检查注释是否符合规范、构建前检查 Java 注释风格。
ExecutorService executor = Executors.newFixedThreadPool(3);
ExecutorCompletionService<String> completionService =
new ExecutorCompletionService<>(executor);
// 提交多个任务
completionService.submit(() -> {
Thread.sleep(2000);
return "结果来自任务A";
});
completionService.submit(() -> {
Thread.sleep(1000);
return "结果来自任务B（最快）";
});
completionService.submit(() -> {
Thread.sleep(3000);
return "结果来自任务C";
});
// 获取第一个完成的任务结果
try {
String firstResult = completionService.take().get();
System.out.println("最先完成的任务结果：" + firstResult);
} catch (Exception e) {
e.printStackTrace();
}
executor.shutdown();
在这个例子中，尽管任务B耗时最短，但它并不是第一个被提交的。通过 completionService.take()，我们直接获取到最先完成的任务的 Future，然后调用 get() 取得结果。整个过程无需等待其他任务结束。
实际应用场景与优化建议
该机制特别适用于以下场景：
- 多路数据查询：从多个API或数据库获取相同类型数据，取最先返回的结果，提升响应速度。
- 冗余调用降级：在高可用设计中，向多个服务实例发起请求，只要一个成功即可返回。
- 竞态任务执行：多种算法计算同一问题，取最先出结果的方案。
优化建议：
- 合理控制线程池大小，避免资源浪费。
- 及时关闭线程池，防止内存泄漏。
- 若只需第一个结果，可在获取后取消其余任务：
executor.shutdownNow()或手动管理 Future 引用并调用cancel(true)。 - 注意异常处理，任务内部抛出的异常会在
future.get()时以 ExecutionException 抛出。
基本上就这些。通过 ExecutorCompletionService，你可以轻松实现“谁快谁先上”的并发策略，显著提升程序的响应效率和用户体验。不复杂但容易忽略。
