CompletableFuture allof（..）。join（）与CompletableFuture.join（）

CompletableFuture allof（..）。join（）与CompletableFuture.join（）

首先，

.getNow()

它不起作用，因为对于将来尚未完成的情况，此方法需要一个后备值作为参数。由于您假设将来会在这里完成，因此您也应该使用

join()

。

然后，线程耗尽没有任何区别，因为在任何一种情况下，您都在等待所有作业的完成之后再继续 *** 作，从而有可能阻塞当前线程。

避免这种情况的唯一方法是，重构代码以使其不期望同步结果，而是安排在完成所有作业后执行后续处理动作。然后，使用

allOf

变得很重要：

final List<CompletableFuture<List<Test>>> completableFutures = resolvers.stream()    .map(resolver -> supplyAsync(() -> task.doWork()))    .collect(toList());CompletableFuture.allOf(completableFutures.toArray(new CompletableFuture<?>[0]))    .thenAccept(justVoid -> {        // here, all jobs have been completed        final List<Test> tests = completableFutures.stream() .flatMap(completableFuture -> completableFuture.join().stream()) .collect(toList());        // process the result here    });

顺便说一句，关于

toArray

收藏的方法，我建议阅读《远古智慧的数组》 …