whenComplete（）如何在CompletionStages链中工作？

Question

我以为我理解了，但我现在不确定。这个问题源于另一条线索。

在我的公司，我们处理期货的方式是将它们链接起来：

CompletionStage<Foo> getFoo() {
  // ...
  return barService.getBar()
      .thenCompose(bar -> {
        CompletionStage<Baz> baz = bazService.getBaz(bar);
        // ...
        return qux;
      })
      .thenApply(qux -> {
        CompletionStage<Quux> quux = quuxService.getQuux(qux);
        // ...
        return foo;
      });
}

qux和qux显然是foo、bar和baz之后的元语法变量

现在，假设我想在收到foo后发送一封确认电子邮件。我不需要发送这封确认邮件来阻止对任何被称为getFoo的客户端的响应。对于这些场景，我们在完成时使用：

CompletionStage<Foo> getFoo() {
  // ...
  return barService.getBar()
      .thenCompose(bar -> {
        CompletionStage<Baz> baz = bazService.getBaz(bar);
        // ...
        return qux;
      })
      .thenApply(qux -> {
        CompletionStage<Quux> quux = quuxService.getQuux(qux);
        // ...
        return foo;
      })                                     _
      .whenComplete((foo, ex) -> {.           |
          if (ex == null) {                   |
            emailService.sendEmail(foo);      | (NEW)
          }                                   |
      });                                    _|
}

现在我认为当完成时的动作发生在一个独立的线程中，完全独立于它起源的线程。换句话说，我认为只要找到foo，它就会被发送到调用方，无论在完成时内部发生了什么。但在现实中，当电子邮件服务出现问题并引发异常时，异常会一直向上传播，即即使成功找到了getFoo，也会引发异常。

我被指向Javadoc for whincomplete，它确实说：

与方法句柄不同，此方法不是为转换完成结果而设计的，因此提供的操作不应引发异常。但是，如果确实如此，则适用以下规则：如果此阶段正常完成，但提供的操作引发异常，则返回的阶段异常完成，提供的操作出现异常。或者，如果此阶段异常完成，并且提供的操作引发异常，那么返回的阶段将异常完成，并出现此阶段的异常。

这就是我困惑的地方：

我认为当完成时的全部目的是允许原始线程继续前进，而无需等待when完成中的操作。如果链是否会正常完成取决于when完成动作，这不是意味着链总是必须等待when完成如何完成吗？如果是真的，when完成有什么帮助？

我肯定我在想一些错误/误解未来是如何运作的，但我不知道是什么。

Answer 1

<代码>。whenComplete类似于finally块。当你想做某事时，即使前一个阶段失败了，它也很有用。例如，在不停止故障传播的情况下记录异常或清理某些资源。

在您的情况下，您似乎只想在没有失败的情况下发送电子邮件。您可以将其重写为：

.thenAccept(emailService::sendEmail);

在这种情况下，如果发送电子邮件返回void，。方法完成后，将返回Accept。但是如果sendmail返回一个CompletionStage

如果您想控制线程执行器，可以使用。然后是*异步方法，而不是常规方法。否则，管道将在同一个线程中运行所有内容（如果可能，情况并非总是如此）。