等待 List<CompletableFuture<Void>> 以指示所有操作已完成的正确方法

Question

我正在使用runAsync((运行数百个函数。所有函数都会修改一些静态可用列表，因此不需要返回任何内容。在继续处理之前，我想确保它们都完成。这是合适的等待方式吗？有没有一种更简单的方法来完成我想要做的事情？

List<CompletableFuture<Void>> futures = new ArrayList<>();
active_sites.forEach(site -> site.getEntryPoints().stream().map(EntryPoint::scanEntryPoint).forEach(futures::add));
CompletableFuture.allOf(futures.toArray(new CompletableFuture[futures.size()])).join();

Answer 1

您可以将其简化很多：

CompletableFuture[] scans = active_sites.stream()
.flatMap(site -> site.getEntryPoints().stream())
.map(EntryPoint::scanEntryPoint)
.toArray(CompletableFuture[]::new)
CompletableFuture.allOf(scans).join();