ExecutorCompletionService能按任务完成顺序获取结果，适用于多数据源查询等需快速响应的场景；通过将Executor与阻塞队列结合，提交任务后调用take().get()即可获取首个完成任务的结果，避免轮询Future的开销；示例中任务B最快完成，即使非首提交也能优先返回；建议合理配置线程池、及时关闭资源，并在获取结果后取消剩余任务以提升效率。
在Java并发编程中，有时我们并不关心所有任务的执行顺序，而是希望尽快拿到最先完成的任务结果，比如在多个数据源查询中取最快返回的结果。这种场景下，ExecutorCompletionService 是一个非常实用的工具。它能帮助我们高效获取最先完成的异步任务，提升系统响应速度。
什么是ExecutorCompletionService？
ExecutorCompletionService 是 Java 提供的一个包装类，它将 Executor 和一个阻塞队列结合起来，用于提交任务并按任务完成的先后顺序获取结果。与直接使用 ExecutorService.submit() 返回 Future 列表再轮询不同，CompletionService 内部维护了一个 BlockingQueue，每有一个任务完成，其 Future 就会被放入队列，从而实现“谁先完成就先处理谁”。
它的核心优势是：避免了手动遍历 Future 列表调用 get() 的阻塞等待，提升了任务结果处理的实时性。
如何使用CompletionService获取最先完成的任务
以下是一个典型使用示例，展示如何从多个并发任务中获取第一个完成的结果：
立即学习“Java免费学习笔记（深入）”；
ExecutorService executor = Executors.newFixedThreadPool(3); ExecutorCompletionServicecompletionService = 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，你可以轻松实现“谁快谁先上”的并发策略，显著提升程序的响应效率和用户体验。不复杂但容易忽略。
