gpt4 book ai didi

java - 如何在同一 Java 流中正确提交和获取多个 Futures?

转载 作者:行者123 更新时间:2023-11-29 08:35:38 24 4
gpt4 key购买 nike

我尝试在同一流中提交并获得 10 个 Future。每个都需要 1 秒来处理,我想并行运行它们。

我的第一个尝试是 takes_10_sec(),它按顺序运行并耗时 10 秒。

我的第二个尝试是 takes_1_sec(),它并行运行并占用 1s。但是它使用中间 .collect(Collectors.toList()).stream() 我认为这不是一个好方法。

还有其他推荐的方法吗?

public class FutureStream {
private ExecutorService executor = Executors.newFixedThreadPool(10);;

@Test
public void takes_10_sec() {
IntStream.range(0, 10)
.mapToObj(i -> longTask())
.map(task -> {
try {
return task.get();
} catch (InterruptedException | ExecutionException e) {
throw new RuntimeException(e);
}
})
.forEach(System.out::println);
}

@Test
public void takes_1_sec() {
IntStream.range(0, 10)
.mapToObj(i -> longTask())
.collect(Collectors.toList())
.stream()
.map(task -> {
try {
return task.get();
} catch (InterruptedException | ExecutionException e) {
throw new RuntimeException(e);
}
})
.forEach(System.out::println);
}

private Future<String> longTask() {
return executor.submit(() -> {
Thread.sleep(1000);
return Thread.currentThread().getName();
});
}
}

最佳答案

流是惰性的,只会根据终端操作的需要处理元素。对于每个元素,在开始下一个元素之前处理整个管道(并行流除外)。例如,此技术允许进行短路操作。

由于您有一个中间 map() 操作会阻塞所创建的 future 的结果,因此处理它将等待每个 future 完成,然后再创建下一个。

像您一样收集它们可以确保首先创建所有 future 。这是合适的解决方案,因为您需要确保在处理结果之前处理整个流。

关于java - 如何在同一 Java 流中正确提交和获取多个 Futures?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/44298581/

24 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com