同时运行Void CompletionStage，但忽略result

Question

我有两个completionStages方法调用，如果一个条件不满足，每个调用一个远程服务。它们都是相当长的运行过程，我们需要减少延迟。我也不关心第二个未来的回应。它可以返回CompletionStage ，因为我只关心该方法是否在退出main方法之前运行。增加的复杂性是injectedclass2.serviceCall还会抛出一个非常重要的异常(404StatusRuntimeException)，需要向客户机显示该异常。

如何确保第一个和第二个future异步运行（不相互依赖），同时第二个future为客户机显示其错误代码和异常。

try {
      .
      .
      .
      CompletionStage<Response> firstFuture;
      CompletionStage<Response> secondFuture = CompletableFuture.completedFuture(Response.default());
      if (condition) {
        firstFuture = legacyImplThing.resolve(param1, param2);
      } else {
        firstFuture =
            injectedClass1.longRunningOp(param1, param2);
        secondFuture = injectedClass2.serviceCall(param1, param2, someOtherData);
      }

      final CompletionStage<MainMethodResponse> response =
          CompletableFutures.combine(firstFuture, secondFuture, (a, b) -> a)
              .thenApply(
                  v -> ServiceResponse.newBuilder().setParam(v.toString()).build());

      handleResponse(response, responseObserver);
    } catch (Exception e) {
      responseObserver.onError(e);
    }

Answer 1

链接其他阶段不会改变以前的阶段。换句话说，并行性完全不在您的控制范围之内，因为它已经被确定了。

更具体地说，当您调用injectedclass1.longrunningop(param1,param2)时，方法longrunningop的实现决定返回的future将如何完成。同样，当调用injectedclass2.serviceCall(param1,param2,someOtherData)时，serviceCall的实现将决定返回的future是否完成。这两种方法可以在幕后使用相同的执行者，也可以使用完全不同的方法。

唯一可以影响并行性的情况是，这两个方法都在调用者的线程中执行实际操作，最终返回已经完成的将来。在这种情况下，您必须将每个调用封装到另一个异步操作中，以让它们并行运行。但是，在调用者的线程中执行一个冗长的操作时返回一个将来，这将是一个奇怪的设计。

您的代码

CompletableFutures.combine(firstFuture, secondFuture, (a, b) -> a)

与文档化的API不匹配。一个有效的调用将是

firstFuture.thenCombine(secondFuture, (a, b) -> a)

在本例中，您不影响FirstFuture或SecondFuture的完成。您只是指定在两个期货都完成后应该发生什么。

firstFuture.thenCombine(secondFuture,
    (v, b) -> ServiceResponse.newBuilder().setParam(v.toString()).build())

首先。