为什么CompletableFuture.allOf被声明为CompletableFuture<Void>？

Question

为什么CompletableFuture.allOf被声明为CompletableFuture<Void>而不返回结果集合或其他什么？我认为让CompletableFuture.anyOf返回CompletableFuture<Object>是个好主意，但我看到这两种方法是相互关联的，所以我对它们返回的内容感到困惑。

Answer 1

anyOf必须以某种方式告诉您，其完成触发anyOf的特定CompletableFuture的结果是什么。对于allOf来说，这是不必要的，因为你知道哪个期货完成了--所有这些。

allOf (就像anyOf一样)并不要求所有期货都有相同的类型。因此，如果它要返回一个集合的未来，它必须是一个Object集合，这可能不是您想要的。

如果您真的想让allOf返回未来的集合，那么编写您自己的集合是非常简单的：

public static CompletableFuture<List<Object>> myAllOf(CompletableFuture<?>... futures) {
     return CompletableFuture.allOf(futures)
            .thenApply(x -> Arrays.stream(futures)
                    .map(f -> (Object) f.join())
                    .collect(toList())
            );
}

如果您有此问题的类型安全版本，并且需要将某一类型的期货集合转换为同一类型集合的未来集合，请参阅此问题中的几个示例： sequence。

Answer 2

这与Misha的回答类似，但有一个通用类型：

public class Futures {
    public static <T> CompletableFuture<List<T>> all(List<CompletableFuture<T>> futures) {
        CompletableFuture<Void> cfv = CompletableFuture.allOf(futures.toArray(new CompletableFuture[0]));
        return cfv.thenApply(future -> {
            return futures.stream()
                    .map(completableFuture -> completableFuture.join())
                    .collect(Collectors.toList());
        });
    }
}

这是Java应该提供的方法。