代码之家 › 专栏 › 技术社区 › ChrisNY

如何在Java中等待所有异步调用完成?

completable-future java-8 parallel-processing asynchronous java

ChrisNY · 技术社区 · 7 年前

但我们确实需要得到所有的结果,并在继续之前将它们结合起来。很明显,我们应该能够并行地进行这十几个调用,但要等待它们全部完成,以便在下一步中使用它们的数据。

我听说Java8有一套非常棒的新操作 CompletableFuture . 但我还没有找到我的用途解释。我们不希望结果是一个承诺-我们很高兴等到他们全部完成,然后继续。JS有 Promise.all() ,但即使这样也会回报一个承诺。

我所能想到的就是在异步调用完成后稍微等待一下,并且只有在得到所有结果后才能继续。显然是疯了。

我是不是漏了什么?因为这对我来说太明显了,但似乎没有其他人对此有问题,或者说方法太简单了,没人愿意问,我就是不明白。

1 回复 | 直到 7 年前

Tomasz Linkowski 7 年前

如果我理解正确,你会想要这样的东西:

ExecutorService executorService = Executors.newFixedThreadPool(4); // TODO: proper number of threads

Future<Integer> future1 = executorService.submit(() -> callService1()); // TODO: proper type and method
Future<String> future2 = executorService.submit(() -> callService2()); // TODO: proper type and method

executorService.shutdown();
executorService.awaitTermination(5, TimeUnit.MINUTES); // TODO: proper timeout

Integer result1 = future1.get(); // TODO: proper type
String result2 = future2.get(); // TODO: proper type

ExecutorService 有4个线程,您可以向其中提交所有任务(即对微服务的调用)
ExecutorService.shutdown ExecutorService.awaitTermination (等到 全部的 任务已完成)
最后,你打电话来 Future.get 在所有的未来得到结果
- 请注意,如果任务在执行期间引发异常,则将抛出一个 ExecutionException 它封装了任务抛出的异常

推荐文章

Niobos · 如何/是否有方法使通用算法函数同时与同步和异步函数一起工作?

1 年前

Rami Dhouib · Flutter:如果等待时间超过2秒,则执行操作

1 年前

Jess The Witch · GCP云功能中处理延迟任务的模式

1 年前

justiceorjustus · Javascript中异步递归函数块内部是否有同步函数调用?

1 年前

Plup · 连接失败时,PyMongo异步客户端未引发异常

1 年前

user1233894 · 尝试从全局函数传递值

1 年前

ZNackasha · 如何将Arc<RwLock<dyn Child>>转换为Arc<RwLock<dyn-Base>>

1 年前

Grigory Turlykin · 发送媒体python电报机器人(ASYNC)

1 年前

Fabiano Taioli · 管理单线程Rust中的阻塞函数

1 年前

river7816 · 为什么spdlog不在async函数中打印

1 年前