如何使用 CompletableFuture 并行运行多个服务调用？

Question

我正在向用户返回以下响应

class FinalResponseDTO {
    List<Service1ResponseDTO> service1ResponseDTO;
    Long totalCount;
    List<Service2ResponseDTO> service2ResponseDTO;
}

截至目前，我正在进行三个连续调用来计算 this FinalResponseDTO，每个调用都可以独立于其他调用运行。我尝试制作三种不同CompletableFuture的：

CompletableFuture<List<Service1ResponseDTO> future1 = CompletableFuture.supplyAsync(() -> service1.callMethod1());
CompletableFuture<Long> future2 = CompletableFuture.supplyAsync(() -> service2.callMethod2());
CompletableFuture<Service2ResponseDTO> future3 = CompletableFuture.supplyAsync(() -> service3.callMethod3());

如果我这样做CompletableFuture.allOf(future1, future2, future3).join();或我应该打电话吗CompletableFuture.allOf(future1, future2, future3).get();？即使我调用其中任何一个join，或者get我应该如何FinalResponseDTO从中构建。我对 Java 8 并发功能不熟悉，例如，CompletableFuture我很困惑，因为每个 future 的返回类型都不同，我应该如何获得所有这些 future 的组合响应，然后构造我的最终输出？

Answer 1

来自以下 Javadoc CompletableFuture.allOf()：

返回一个新的 CompletableFuture，当所有给定的 CompletableFuture 完成时，该 CompletableFuture 也完成。如果任何给定的 CompletableFuture 异常完成，则返回的 CompletableFuture 也会异常完成，并且 CompletionException 会将此异常作为其原因。否则，给定 CompletableFuture 的结果（如果有）不会反映在返回的 CompletableFuture 中，但可以通过单独检查它们来获得。

因此，当组合 CompletableFuture 完成时，您可以通过应用构造对象的函数来检查值并使用简单的构造函数构造最终响应对象：

CompletableFuture.allOf(future1, future2, future3).thenApply(v -> 
    new FinalResponseDTO(future1.join(), future2.join(), future3.join())
);