java - 同时运行 Void CompletionStage 但忽略结果

Question

我有两个 completionStages 方法调用，如果不满足条件，每个方法调用一个远程服务。它们都是长时间运行的进程，我们需要减少延迟。我也不关心 secondFuture 的响应。它可以返回 CompletionStage<Void>因为我只关心该方法是否在我们退出 main 方法之前运行。一个额外的复杂性是 injectedClass2.serviceCall还会抛出一个非常重要的异常 (404 StatusRuntimeException)，需要向客户端显示。

我如何确保第一个和第二个 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);
    }

可能超出范围，如何测试/检查两个 completionStages 是否同时运行？

编辑:CompletableFutures.combine()是第三方库方法，不是 java.util.concurrent 包的一部分。

Answer 1

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

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

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

你的代码

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

不匹配the documented API .一个有效的调用是

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

在这种情况下，您不会影响 firstFuture 或 secondFuture 的完成。您只是指定两个 futures 完成后应该发生什么。

顺便说一句，没有理由在 thenCombine 中指定像 (a, b) -> a 这样的微不足道的函数，只是为了链接另一个 然后应用。你可以使用

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

首先。