如何实现CompletableFuture.allOf（），一旦任何期货失效，它就会异常完成？

Question

我要实现的混合，CompletableFuture.allOf()并且CompletableFuture.anyOf()一旦所有要素都成功完成，返回的未来就成功完成，或者一旦任何要素都异常完成，它就异常地完成（相同的例外）。如果多个元素失败，则返回其中任何一个的异常就足够了。

用例

我有一个任务需要汇总由CompletableFutures
列表返回的子结果，但是一旦其中任何一个失败，该任务就应该停止等待。我知道子任务将继续运行，这没关系。

相关问题

我发现在“
等待”列表上等待，最初看起来像是一个重复的问题，但被接受的答案使用CompletionService了要求Callable或Runnable作为输入的内容。我正在寻找一个将已经运行的CompletionStages作为输入的解决方案。

Answer 1

这个问题实际上与使用Java 8CompletableFuture替换Futures.successfulAsList十分相似。

尽管问题并不完全相同，但相同的答案（来自我自己）应该可以满足您的需求。

您可以结合使用来实现此功能，allOf()并使用将每个输入的future与链接起来exceptionally()，这样会使allOf()立即返回的future
失败：

CompletableFuture<String> a = …, b = …, c = …;
CompletableFuture<Void> allWithFailFast = CompletableFuture.allOf(a, b, c);
Stream.of(a, b, c)
    .forEach(f -> f.exceptionally(e -> {
        allWithFailFast.completeExceptionally(e);
        return null;
    }));