为什么调用 CompletableFuture::cancel 会立即导致 CancellationException

Question

我正在尝试在CompletableFuture 上致电cancel。

从文档看来：

如果尚未完成，则使用 CancellationException 完成此 CompletableFuture。尚未完成的依赖 CompletableFuture 也将异常完成，并由此 CancellationException 引发 CompletionException。

它应该异常地完成它们，这是我所期望的，但相反，它会抛出并立即 CancellationException。

这是一个示例代码

CompletableFuture<?> f = CompletableFuture.supplyAsync(() -> false);
f.cancel(true);  // Line 7.
f.join();

有一个再现：https://www.mycompiler.io/view/2v1ME4u

Exception in thread "main" java.util.concurrent.CancellationException
    at java.base/java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2396)
    at Main.main(Main.java:7)

第 7 行是 f.cancel(true); 行。

Answer 1

它实际上并没有立即抛出。

调用f.cancel(true) 会创建一个CancellationException，捕获调用cancel 的堆栈跟踪。因此堆栈跟踪（由于未处理而被打印）包含f.cancel(true); 调用的行。

但直到f.join() 才真正引发该异常：

完成时返回结果值，如果异常完成则抛出（未经检查的）异常

...

投掷：

CancellationException - 如果计算被取消

您可以通过添加更多打印语句into your example code 来看到这一点：

CompletableFuture<?> f = CompletableFuture.supplyAsync(() -> false);
f.cancel(true);  // Line 8.
try {
    f.join();
} catch (CancellationException e) {
    System.out.println("CancellationException was thrown at call to f.join()");
    e.printStackTrace(System.out);
}

输出：

CancellationException was thrown at call to f.join()
java.util.concurrent.CancellationException
    at java.base/java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2396)
    at Main.main(Main.java:8)