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