CompletableFuture.allOf当一个期货抛出异常[duplicate]时取消其他期货

Question

Java 8的< code > CompletableFuture . allof(CompletableFuture

如果我的一个期货异常完成，那么< code > completablefuture . allof 会在抛出< code>CompletionException之前等待其余期货完成，还是会取消其余期货？

如果它等待所有期货完成，有没有办法让它在任何期货抛出异常并取消剩余期货时立即返回？

Answer 1

如果我的某个未来完成时出现异常，则它将＜code＞CompletableFuture。allOf等待剩余的期货完成，然后抛出＜code＞CompletionException

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

您可以使用这个帮助器方法来创建一个< code>CompletableFuture，一旦任何期货异常完成，它就会异常完成。

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));
}

如果您还想取消所有其他期货（如果其中一个期货异常完成），您可以在从此方法返回之前这样做：

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