我尝试提交并获得 10Future
s 在同一个流中。每个都需要 1 秒来处理,我想并行运行它们。
我的第一次尝试是takes_10_sec()
它按顺序运行,需要 10 秒。
我的第二次尝试是takes_1_sec()
并行运行,耗时 1 秒。然而它使用了一个中间体.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 完成,然后再创建下一个。
像你一样收集它们可以确保首先创建所有的未来。这是合适的解决方案,因为您需要确保在处理结果之前处理整个流。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)