所有期货都会传递给 CompletableFuture.allOf() 运行吗？

Question

所以我有几个想要运行的未来，即使有些失败了，我希望所有人都有机会运行。所以如果我这样做：

CompletableFuture.allOf(futures).join()

会是这样吗？我的理由是，每个 future 都会在其执行程序中有自己的队列作业，因此如果主线程没有首先完成，那么所有 future 都会运行。我的问题是我在 .allOf() 上专门 .join() 所以我的申请不会在运行完成所有事情

之前结束

所以 allOf() 语义让我感到困惑：当所有已通过的期货完成时，未来 return 是否会完成，无论是否成功？或者如果它看到一个失败而不等待其余的，它会完成一个失败的未来吗？

编辑

为了进一步说明我的问题，.allOf 的行为是否像这样：

Stream.of(futures).forEach(future -> {
  try {
    future.join()
  } catch (Throwable e) {
    //dont throw, we want to join the rest
  }
})

或者它的行为是否如下所示：

Stream.of(futures).forEach(future -> {
  try {
    future.join()
  } catch (Throwable e) {
    throw e; //All other remaining .join() wont run
  }
})

这是哪个？第一种还是第二种情况？因为我想要第一种情况，这就是我暂时在我的代码中使用的情况，但我想尽可能使用 allOf() 因为它更美观

谢谢！

Answer 1

是的，每个未来都将独立尝试完成。

我想你也在试图理解控制在各种场景下是如何流动的。我想出了 4 个场景：

由于未处理的异常而导致失败的未来
应明确标记为失败并带有 completeExceptionally 且尾部有异常块的未来。
应明确标记为失败且带有 completeExceptionally 且尾部没有异常块的未来。
一个成功的未来。

//CASE 1
// A future that shall fail due to an unandled exception in its run 
// and has an exceptionally block at its tail
CompletableFuture<Void> unhandledFailureFutureWithExceptionHandler =
    CompletableFuture.runAsync(() -> {
        throw new RuntimeException("Exception in unhandledFailureFutureWithExceptionHandler");
    });
unhandledFailureFutureWithExceptionHandler = unhandledFailureFutureWithExceptionHandler
    .exceptionally(throwable -> {
        // Handling exception for this future
        // HANDLING POINT 1
        System.out.println("Handling exception at HANDLING POINT FOR CASE 1, 
            failure message is : " + throwable.getMessage());
        return null;
    });

//CASE 2
//A future that shall fail and has an exceptionally block at its tail
CompletableFuture<Void> failedFutureWithExceptionHandler = new CompletableFuture<>();
failedFutureWithExceptionHandler.completeExceptionally(
    new RuntimeException("Exception in failedFutureWithExceptionHandler")
);
failedFutureWithExceptionHandler = failedFutureWithExceptionHandler.exceptionally(throwable -> {
    // Handling exception for this future
    // HANDLING POINT 2
    System.out.println("Handling exception at HANDLING POINT FOR CASE 2, 
        failure message is : " + throwable.getMessage());
    return null;
});

//CASE 3
//A future that shall fail and has no exceptionally block at its tail
CompletableFuture<Void> failedFutureWithoutExceptionHandler = new CompletableFuture<>();
failedFutureWithoutExceptionHandler.completeExceptionally(
    new RuntimeException("Exception in failedFutureWithoutExceptionHandler")
);

//CASE 4
//A future that shall succeed and print a message to console
CompletableFuture<Void> successFuture = CompletableFuture.runAsync(() -> 
    System.out.println("CASE 4 : Running successFuture")
);

CompletableFuture.allOf(unhandledFailureFutureWithExceptionHandler, 
    failedFutureWithExceptionHandler, failedFutureWithoutExceptionHandler, successFuture)
        .exceptionally(throwable -> {
            // Handling exception if ANY of the futures that did not have its own exceptionally block
            // In this case the exception of `failedFutureWithoutExceptionHandler` will be handled here
            // HANDLING POINT 3
            System.out.println("Handling exception at HANDLING POINT FOR CASE 3, 
                failure message is : " + throwable.getMessage());
            return null;
        }).join();

控制台上产生的输出是

Handling exception at HANDLING POINT FOR CASE 1, failure message is : java.lang.RuntimeException: Exception in unhandledFailureFutureWithExceptionHandler
Handling exception at HANDLING POINT FOR CASE 2, failure message is : Exception in failedFutureWithExceptionHandler
CASE 4 : Running successFuture
Handling exception at HANDLING POINT FOR CASE 3, failure message is : java.lang.RuntimeException: Exception in failedFutureWithoutExceptionHandler

如您所见，未来是否像案例 1 一样抛出未处理的错误，如果它有一个 exceptionally 块链接到它的尾部，则应在该点处理异常

对于情况 2，如果 future 被标记为 completeExceptionally 失败，如果 future 有一个处理程序链接到它的尾部，那么 exceptionally 块应由该处理程序处理块

在情况3中，未来被标记为失败并且没有异常块，因此它应该由下一级的exceptionally块处理，在这种情况下是exceptionally allOf().

块

如您所见，案例 4 运行完成，并且无论其他 futures 是否失败，消息都会打印在控制台上。

所有期货都会传递给 CompletableFuture.allOf() 运行吗？

Will all futures passed to CompletableFuture.allOf() run?

java

semantics

completable-future

所有期货都会传递给 CompletableFuture.allOf() 运行 吗？

Will all futures passed to CompletableFuture.allOf() run?

java

semantics

completable-future

所有期货都会传递给 CompletableFuture.allOf() 运行吗？