ExecutorCompletionService能按任务完成顺序获取结果，提升响应效率。它结合线程池与阻塞队列，将已完成任务的Future放入队列，通过take()或poll()获取结果，实现“谁先完成，谁先处理”。相比invokeAll的顺序等待，CompletionService更适合搜索服务、性能差异大的批量任务等需快速响应的场景。使用时需注意关闭线程池、避免过早调用take()导致阻塞，并合理处理异常和超时。
在Java并发编程中，当需要提交多个任务并逐个获取执行结果时，ExecutorCompletionService 是一个非常实用的工具。它结合了 ExecutorService 和 BlockingQueue 的特性，能够按任务完成顺序获取结果，而不是按照提交顺序，从而提升响应效率。
ExecutorCompletionService 基本原理
ExecutorCompletionService 内部维护一个线程池和一个阻塞队列。每当有任务完成，其结果（Future对象）会被放入队列中。调用者可以通过 take() 或 poll() 方法从队列中获取已完成任务的结果，实现“谁先完成，谁先处理”。
关键点：
- 基于生产者-消费者模式：任务是生产者，结果处理是消费者。
- 内部使用 BlockingQueue 存储已完成任务的 Future 对象。
- 避免主线程等待所有任务结束，提高实时性。
如何使用 ExecutorCompletionService 获取任务结果
以下是一个典型使用示例，演示如何提交多个可计算任务，并按完成顺序处理结果。
立即学习“Java免费学习笔记（深入）”；
import java.util.concurrent.*;
<p>public class CompletionServiceExample {
public static void main(String[] args) {
ExecutorService executor = Executors.newFixedThreadPool(4);
ExecutorCompletionService<Integer> completionService =
new ExecutorCompletionService<>(executor);</p><pre class="brush:php;toolbar:false;"> // 提交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。
基本上就这些。通过合理使用 ExecutorCompletionService，可以让多任务并发处理更高效、响应更快。关键是理解“结果驱动”的处理思路，而不是“顺序驱动”。
