Java中Callable配合CompletionService天然支持“谁空闲谁先处理”，因其基于阻塞队列+线程池，任务提交即入队，空闲线程自动取任务执行；CompletionService解耦提交与结果获取，任务异步执行后结果入BlockingQueue，take()/poll()按完成顺序获取结果，适合批量HTTP请求等场景。

Java中用Callable配合CompletionService，天然支持“谁空闲谁先处理”，不需要额外控制逻辑——因为CompletionService底层基于阻塞队列+线程池，任务提交后立即入队，空闲线程会自动从队列里取任务执行。

CompletionService 的核心机制

CompletionService把任务提交和结果获取解耦：任务由线程池异步执行，执行完的结果被放进内部的BlockingQueue（如LinkedBlockingQueue）。只要线程池中有空闲线程，它就会立刻从任务队列中拉取新任务，无需等待或调度干预。

• 提交任务调用submit(Callable)，不阻塞，立刻返回Future
• 获取结果调用take()或poll()，阻塞/非阻塞地等任意一个任务完成
• 线程池本身负责线程复用和空闲调度，CompletionService只是包装了一层结果归集

典型用法：提交一批任务，按完成顺序消费

适合需要“谁先算完谁先处理”的场景，比如批量HTTP请求、并行计算、资源探测等。

Java Maven Common

Java Maven 项目审查工作流的通用输入处理。当 Java Maven 项目以 ZIP压缩包或 GitLab 仓库 URL 形式提供且需要...时使用。

下载

• 创建ExecutorService（推荐ThreadPoolExecutor，可设核心线程数和队列策略）
• 用该线程池构造ExecutorCompletionService
• 循环submit()多个Callable任务
• 循环take()——每次拿到最先完成的那个Future，再get()取结果

关键细节：线程池配置影响“空闲优先”效果

所谓“空闲线程先得”，本质依赖线程池的执行策略。若配置不当，可能无法及时响应：

立即学习“Java免费学习笔记（深入）”；

• 使用newFixedThreadPool(n)时，最多n个并发，空闲线程数 = n − 正在运行任务数，剩余空闲线程会立即抢任务
• 避免用newCachedThreadPool()处理大量短任务——它会无限新建线程，造成资源浪费，且失去可控性
• 自定义ThreadPoolExecutor时，建议设置合理corePoolSize和workQueue，让任务排队而非拒绝或扩容

一个小例子：模拟3个耗时不同的任务

假设有三个Callable，执行时间分别为1s、3s、2s。提交后调用三次take().get()，结果顺序一定是1s任务、2s任务、3s任务——不是提交顺序，而是完成顺序，背后就是空闲线程持续拉取+最快完成者优先进入完成队列。

注意：take()是阻塞的，如果所有任务都未完成，会一直等；poll()可设超时，适合有等待上限的场景。