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

Question

我将以下响应返回给用户

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

到目前为止，我正在进行三次连续调用来计算这个FinalResseDTO，每个调用都可以独立于其他调用运行。我尝试制作三种不同的CompletableFuture作为：

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

如果我做了CompletableFuture。所有（未来1、未来2、未来3）。join（） 或者我应该调用CompletableFuture。所有（未来1、未来2、未来3）。get（） ？即使我调用了这些join或get中的任何一个，那么我应该如何从中构造FinalResponseDTO。我不熟悉Java 8并发特性，例如CompletableFuture，我很困惑，因为每个future的每个返回类型都不同，我应该如何获得所有这些future的组合响应，然后构造最终输出？




Answer 1

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

    CompletableFuture.allOf(future1, future2, future3).get();

    return new FinalResponseDTO(future1.join(), future2.join(), future3.join());

注意：supplyAsync在ForkJoinPool上运行。commonPool（）因此，提供您自己的执行器（例如执行器）是一个不错的选择。newCachedThreadPool（）：

CompletableFuture.supplyAsync(() -> action, executor);

Answer 2

来自CompletableFuture的Javadocs。anyOf（）：

返回一个新的CompletableFuture，该Future在所有给定CompletableFutures完成时完成。如果任何给定的CompletableFutures异常完成，那么返回的CompletableFutures也会这样做，CompletionException将此异常作为其原因。否则，给定的CompletableFutures的结果（如果有）不会反映在返回的CompletableFutures中，而是可以通过单独检查来获得。

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

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

正如所暗示的，您应该始终检查Javadoc中的方法行为，例如get（）vsgetNow（）。我在这里使用后者是为了避免异常处理，因为在allOfCompletableFuture正常完成后，这些值将保证可用。