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

html5 • • 问答

我正在使用 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();

回答

你可以简化一下：

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

  • Sure, but I think that hurts readability. (Just like your relatively long lambda in `active_sites.forEach`, by the way.)
以上是等待List&lt;CompletableFuture&lt;Void&gt;&gt;指示所有操作已完成的正确方法的全部内容。
THE END
分享
二维码
< <上一篇
下一篇>>