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

Question

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

CompletableFuture.allOf(futures).join()

会这样吗？我的理由是，每个未来都会在其执行程序中拥有自己的队列作业，因此只要主线程没有首先完成，所有的都会运行。我的问题是我在.allOf() 上专门.join() 所以我的应用程序在运行所有内容之前不会结束

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

编辑

为了进一步说明我的问题，.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 个场景：

1. 由于未处理的异常而发生故障的未来
2. 应明确标记为失败的 future 并带有一个 completeExceptionally 并且在其尾部有一个异常块。
3. 应使用 completeExceptionally AND 明确标记为失败的未来，其尾部没有异常块。
4. 将走向成功的未来。

//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

正如你所看到的，如果一个 future 抛出一个未处理的错误，如案例 1，如果它有一个 exceptionally 块链接到它的尾部，则应在该点处理异常

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

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

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