我必须在whenComplete（）中调用join（）来表示未来吗？

Question

我正在向现有endpoint添加一些代码来发送电子邮件。我们不需要发送电子邮件的结果来向用户返回响应，所以我在期货链的末尾添加了一个. whenCompl（），从内部调用我们的电子邮件服务。对电子邮件服务的调用也是异步的，返回一个CompletionStage

CompletionStage<SomeResponse> someEndpoint() {
  return doThings()
      .thenApply(things -> {
        return someResponseFormat(things);
      })
      .whenComplete((someResponse, ex) -> {
        if (ex == null) {
          emailClient.sendEmail(someResponse); // CompletionStage<Void>
        }
      });
}

据我所知，该任务将被安排和执行。我需要在sendEmail（…）上调用join（）吗？这样做与不打电话会有不同的行为吗？最佳实践是什么？

编辑：最初我问我是否需要调用join（）或get（），这被误解为“我需要调用哪一个”，而我的意思是“我到底需要调用哪个”




Answer 1

与emailClient关联的操作。sendEmail（someResponse）将被调度，而不管您是否等待其完成，因此除非JVM同时终止，否则它将完成。但是

> < li>

没有人会注意到操作何时完成或能够等待其完成。

当操作失败并出现异常时，没有人会注意到。

所以你可能想做的是

CompletionStage<SomeResponse> someEndpoint() {
  return doThings()
      .thenApply(things -> someResponseFormat(things))
      .thenCompose(someResponse -> emailClient.sendEmail(someResponse)
          .thenApply(_void -> someResponse));
}

然后，当某个Endpoint（）的调用方在其上调用连接（）时，join（）将等待发送电子邮件的完成，并在发送电子邮件失败时报告错误。同样，当某些Endpoint（）链的调用者依赖操作时，它们将在发送电子邮件完成后启动。