功能性Java-whenComplete与异常之间的交互

一尘不染

功能性Java-whenComplete与异常之间的交互

java

在此代码中：

doSomethingThatMightThrowAnException()
  .whenComplete((result, ex) -> doSomethingElse()})
  .exceptionally(ex -> handleException(ex));

当有一个例外，从doSomethingThatMightThrowAnException，都doSomethingElse和handleException运行，或者是通过异常无论是消费whenComplete还是exceptionally？

编辑：

doSomethingThatMightThrowAnException返回CompletableFuture，可能是completeExceptionally。这是我所谈论的例外。

阅读 530

2020-12-03

共1个答案

一尘不染

的文档whenComplete说：

返回一个 具有与此阶段相同的结果或异常 的新CompletionStage ，该阶段 在此阶段完成时执行给定的操作。

（强调我的）

这意味着该阶段不会吞噬异常，因为它应该具有相同的结果或异常。但是，您可能通过这样的事实感到惊讶的是后续阶段将获得前一阶段内的包裹外CompletionException，所讨论的在这里，所以它不是完全一样的例外：

CompletableFuture<String> test=new CompletableFuture<>();
test.whenComplete((result, ex) -> System.out.println("stage 2: "+result+"\t"+ex))
    .exceptionally(ex -> { System.out.println("stage 3: "+ex); return ""; });
test.completeExceptionally(new IOException());

将打印：

stage 2: null   java.io.IOException
stage 3: java.util.concurrent.CompletionException: java.io.IOException

请注意，您始终可以在一个阶段上附加多个操作，而不是随后进行链接：

CompletableFuture<String> test=new CompletableFuture<>();
test.whenComplete((result, ex) -> System.out.println("stage 2a: "+result+"\t"+ex));
test.exceptionally(ex -> { System.out.println("stage 2b: "+ex); return ""; });
test.completeExceptionally(new IOException());



stage 2b: java.io.IOException
stage 2a: null  java.io.IOException

当然，由于现在阶段2a和之间没有依赖关系2b，因此它们之间没有排序，并且在异步操作的情况下，它们可以同时运行。

2020-12-03