等待一组异步 Java 调用的轻量级方法

Question

我们正在单个阻塞方法中编写一些代码，该方法异步调用多个缓慢的第三方服务。这些异步调用包装在实现相同接口方法的代码中。我们希望触发异步调用并等待它们全部返回，然后再返回阻塞方法调用。

我希望这是清楚的！

是否有合适的设计模式/库来实现这个......它必须是一个相当常见的模式。提前致谢。

Answer 1

您可以使用 CountDownLatch 使用异步调用的数量进行初始化，并让每个异步处理程序递减锁存器。 “外部”阻塞方法将简单地“等待”完整倒计时，例如：

// Untested, Java pseudocode...
public void awaitAllRemoteCalls() {
    final CountDownLatch allDoneSignal = new CountDownLatch(N);
    // For each remote N calls...
    thirdPartyAsyncCall.call(new AsyncHandler(Object remoteData) {
        // Handle the remote data...
        allDoneSignal.countDown();
    });
    allDoneSignal.await();
}

Answer 2

我不确定你是如何做事的，但我会让启动异步任务的任何东西（最好通过使用 Executor）返回 Future对于您开始的每项任务。然后，您只需将所有 Future 放入 Collection 中，并调用 get() 对其进行迭代：

List<Future<?>> futures = startAsyncTasks();
for (Future<?> future : futures) {
  future.get();
}
// all async tasks are finished

I这里省略了 get() 的异常处理，但这就是总体思路。