关于使用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
相关产品推荐
相关产品推荐

