在Java中如何使用ExecutorCompletionService获取任务结果_任务结果并发处理方法解析-java教程-PHP中文网

在Java中如何使用ExecutorCompletionService获取任务结果_任务结果并发处理方法解析

P粉602998670

发布： 2025-11-20 12:06:03

原创

588人浏览过

ExecutorCompletionService能按任务完成顺序获取结果，提升响应效率。它结合线程池与阻塞队列，将已完成任务的Future放入队列，通过take()或poll()获取结果，实现“谁先完成，谁先处理”。相比invokeAll的顺序等待，CompletionService更适合搜索服务、性能差异大的批量任务等需快速响应的场景。使用时需注意关闭线程池、避免过早调用take()导致阻塞，并合理处理异常和超时。

在java中如何使用executorcompletionservice获取任务结果_任务结果并发处理方法解析

在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;"><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
说明耗时短的任务先返回结果。