You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

关于使用ExecutorService的invokeAny获取首个并行执行结果的技术咨询

用ExecutorService的invokeAny实现并行任务取首个结果

我自己写了一个基于ExecutorService的实现,目的是并行执行多个线程任务,并且直接拿到第一个完成的任务结果,核心就是靠invokeAny方法来达成这个需求的。

完整代码示例

import java.util.HashSet;
import java.util.Set;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class Test {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(3);
        Set<Callable<String>> tasks = new HashSet<>();
        
        // 添加几个模拟的Callable任务,各自有不同的执行耗时
        tasks.add(() -> {
            Thread.sleep(1000);
            return "任务1的执行结果";
        });
        tasks.add(() -> {
            Thread.sleep(500);
            return "任务2的执行结果";
        });
        tasks.add(() -> {
            Thread.sleep(1500);
            return "任务3的执行结果";
        });
        
        try {
            // 调用invokeAny获取第一个完成的任务结果
            String firstResult = executorService.invokeAny(tasks);
            System.out.println("最先返回的结果:" + firstResult);
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 记得关闭线程池
            executorService.shutdown();
        }
    }
}

现在我想咨询关于这个实现的相关技术问题。

内容的提问来源于stack exchange,提问作者navy1978

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.05.21 06:56:48