如何异步运行组合完全期货

Question

我希望通过调用不同的服务来加载应用程序启动时的数据，这些服务返回不同对象类型的列表。每个服务调用DAO类来读取一些数据。因此，我创建了个人CompletableFuture如：

CompletableFuture<List<DTO1> future1 = CompletableFuture.supplyAsync(() -> service1.callMethod1());
CompletableFuture<List<DTO2> future2 = CompletableFuture.supplyAsync(() -> service2.callMethod2());
CompletableFuture<List<DTO3> future3 = CompletableFuture.supplyAsync(() -> service3.callMethod3());

并将它们结合起来，如：

CompletableFuture<Void> combinedFuture = CompletableFuture.allOf(future1, future2, future3);

如果我这样做：

combinedFuture.thenRunAsync(()->future1.join(), future2.join(), future3.join())

然后我得到了编译时错误。我不熟悉Java 8的并发特性，例如CompletableFuture，我认为调用thenRunAsync将在不同的线程中运行每个future1、future2、future3。调用thenRunAsync是否正确？如果是，那么如何删除编译时错误？

但是如果我做了这样的事情：

Stream.of(future1, future2, future3)
        .map(CompletableFuture::join)
        .collect(Collectors.toList());

它正在返回列表

Stream.of(future1, future2, future3)
        .foreach(CompletableFuture::join);

它会在不同的线程中运行每个future1、future2、future3？如何在3个不同的线程中运行future1、future2、future3？有没有正确的方法异步运行这三个数据库调用？




Answer 1

CompletableFuture<List<DTO1> future1 = CompletableFuture.supplyAsync(() -> service1.callMethod1());
CompletableFuture<List<DTO2> future2 = CompletableFuture.supplyAsync(() -> service2.callMethod2());
CompletableFuture<List<DTO3> future3 = CompletableFuture.supplyAsync(() -> service3.callMethod3());

这段代码已经指示所有三个未来在不同的线程上运行（假设公共池中至少有3个线程）。对其中一个调用join（）只会指示调用线程在该任务完成时阻塞，并且不会改变这3个调用并行进行的事实。所有编译的解决方案都是合理的。