ExecutorCompletionService能按任务完成顺序获取结果，提升响应效率。它结合线程池与阻塞队列，将已完成任务的Future放入队列，通过take()或poll()获取结果，实现“谁先完成，谁先处理”。相比invokeAll的顺序等待，CompletionService更适合搜索服务、性能差异大的批量任务等需快速响应的场景。使用时需注意关闭线程池、避免过早调用take()导致阻塞，并合理处理异常和超时。
在Java并发编程中，当需要提交多个任务并逐个获取执行结果时，ExecutorCompletionService 是一个非常实用的工具。它结合了 ExecutorService 和 BlockingQueue 的特性，能够按任务完成顺序获取结果，而不是按照提交顺序，从而提升响应效率。
ExecutorCompletionService 基本原理
ExecutorCompletionService 内部维护一个线程池和一个阻塞队列。每当有任务完成，其结果（Future对象）会被放入队列中。调用者可以通过 take() 或 poll() 方法从队列中获取已完成任务的结果，实现“谁先完成，谁先处理”。
关键点：
- 基于生产者-消费者模式：任务是生产者，结果处理是消费者。
- 内部使用 BlockingQueue 存储已完成任务的 Future 对象。
- 避免主线程等待所有任务结束，提高实时性。
如何使用 ExecutorCompletionService 获取任务结果
以下是一个典型使用示例，演示如何提交多个可计算任务，并按完成顺序处理结果。
import java.util.concurrent.*;public class CompletionServiceExample { public static void main(String[] args) { ExecutorService executor = Executors.newFixedThreadPool(4); ExecutorCompletionService
completionService = new ExecutorCompletionService<>(executor); // 提交5个任务 for (int i = 0; i < 5; i++) { final int taskId = i; completionService.submit(() -> { // 模拟不同耗时 Thread.sleep((5 - taskId) * 200); return taskId * 2; }); } // 按完成顺序获取结果 for (int i = 0; i < 5; i++) { try { Integer result = completionService.take().get(); System.out.println("收到结果: " + result); } catch (InterruptedException | ExecutionException e) { e.printStackTrace(); } } executor.shutdown(); }}
输出可能为：
收到结果: 8
收到结果: 6
收到结果: 4
收到结果: 2
收到结果: 0
说明耗时短的任务先返回结果。与直接使用 invokeAll 的区别
如果使用
ExecutorService.invokeAll()，会返回一个 Future 列表，必须按提交顺序遍历获取结果，即使后面的某些任务已经完成，也得等前面的任务全部完成才能继续处理。而 ExecutorCompletionService 允许你立即处理已完成任务，特别适合以下场景：
- 搜索服务：多个数据源并行查询，只要有一个返回就立刻展示。
- 批量处理任务中存在明显性能差异的情况。
- 希望尽早释放资源或触发后续动作。
注意事项与最佳实践
使用时注意以下几点以避免常见问题：
- 记得调用
shutdown() - take() 是阻塞方法，确保所有任务已提交后再循环获取，否则可能一直等待。
- 可以搭配 poll(long timeout, TimeUnit) 实现超时控制，增强健壮性。
- 异常处理不可忽略：get() 可能抛出 ExecutionException。
shutdown()基本上就这些。通过合理使用 ExecutorCompletionService，可以让多任务并发处理更高效、响应更快。关键是理解“结果驱动”的处理思路，而不是“顺序驱动”。
