java - CompletableFuture.allOf 在抛出异常时取消其他 future

Question

这个问题已经有答案了:

How to implement CompletableFuture.allOf() that completes exceptionally once any of the futures fail? (2 个回答)

已关闭 3 年前。

Java 8 CompletableFuture.allOf(CompletableFuture<?>...cfs) 将返回 CompletableFuture当所有给定的 future 完成时完成，或者抛出 CompletionException如果其中一个 future 完成时出现异常。

如果我的其中一个 future 完成时出现异常，将 CompletableFuture.allOf等待剩余的 future 完成后再抛出 CompletionException还是会取消剩余的 future ？

如果它等待所有 future 完成，有什么办法让它在任何 future 抛出异常时立即返回并取消剩余的 future 吗？

Answer 1

If one of my futures completes with an exception, will CompletableFuture.allOf wait for the remaining futures to complete before throwing the CompletionException

是的，它仍然会等待所有 future 完成。

您可以使用此辅助方法创建一个 CompletableFuture，一旦任何 future 完成，它就会异常完成。

public static CompletableFuture allOfTerminateOnFailure(CompletableFuture<?>... futures) {
    CompletableFuture<?> failure = new CompletableFuture();
    for (CompletableFuture<?> f: futures) {
        f.exceptionally(ex -> {
            failure.completeExceptionally(ex);
            return null;
        });
    }
    return CompletableFuture.anyOf(failure, CompletableFuture.allOf(futures));
}

如果您还想取消所有其他 future(如果其中一个 future 异常完成)，您可以在从此方法返回之前执行以下操作:

failure.exceptionally(ex -> {
    Arrays.stream(futures).forEach(f -> f.cancel(true));
    return null;
});