java正在等待所有并行任务,如果任何任务失败,则在将来完成时失败
我正在使用
List<CompletableFuture<String>> futures = list.stream().map(...)
.map(id -> CompletableFuture.supplyAsync(() -> fun()), pool))
.collect(Collectors.toList());
稍后我想将List<CompletableFuture<String>>
转换为CompletableFuture<List<String>>
,然后调用join()
。我想等待它们全部完成;如果至少有一个异常完成,那么我想抛出一个错误
我该怎么做
共 (0) 个答案