等待多个期货的回调答案

【问题标题】：Waiting for callback for multiple futures等待多个期货的回调
【发布时间】：2013-12-10 18:25:57
【问题描述】：

最近我深入研究了一些使用 API 的工作。该 API 使用 Unirest http 库来简化从 Web 接收的工作。自然，由于数据是从 API 服务器调用的，因此我尝试通过对 API 进行异步调用来提高效率。我的想法结构如下：

通过返回期货结果创建数据数组
显示数据 + 从数据中收集的其他信息

因此，我需要在开始第二步之前返回所有数据。我的代码如下：

Future < HttpResponse < JsonNode >  > future1 = Unirest.get("https://example.com/api").asJsonAsync(new Callback < JsonNode > () {
    public void failed(UnirestException e) {
        System.out.println("The request has failed");
    }
    public void completed(HttpResponse < JsonNode > response) {
        System.out.println(response.getBody().toString());
        responses.put(response);
    }
    public void cancelled() {
        System.out.println("The request has been cancelled");
    }
});
Future < HttpResponse < JsonNode >  > future2 = Unirest.get("https://example.com/api").asJsonAsync(new Callback < JsonNode > () {
    public void failed(UnirestException e) {
        System.out.println("The request has failed");
    }
    public void completed(HttpResponse < JsonNode > response) {
        System.out.println(response.getBody().toString());
        responses.put(response);
    }
    public void cancelled() {
        System.out.println("The request has been cancelled");
    }
});
doStuff(responses);

我将如何做到只有在两个期货都完成后才调用 doStuff？

【问题讨论】：

可能想看看ExecutorCompletionService，但如果任何响应完成，您可以做一些事情。
stackoverflow.com/questions/3269445/…

标签： java api concurrency future

【解决方案1】：

有几个选项。您现在拥有的代码从您提出请求的同一线程调用doStuff。如果您想阻塞直到两个请求都完成，您可以使用 CountDownLatch。比如：

CountDownLatch responseWaiter = new CountDownLatch(2);

Future <HttpResponse<JsonNode>> future1 = Unirest.get("https://example.com/api").asJsonAsync(new Callback<JsonNode>() {
  public void completed(HttpResponse<JsonNode> response) {
    responses.put(response);
    responseWaiter.countDown();
  }
  ...
});

// Similar code for the other get call
...

responseWaiter.await();
doStuff(responses);

如果您不想在两个调用都完成之前阻塞该线程，您可以让每个匿名内部回调类增加一个 AtomicInteger。当计数为 2 时，您将调用 doStuff。比如：

AtomicInteger numCompleted = new AtomicInteger();

Future <HttpResponse<JsonNode>> future1 = Unirest.get("https://example.com/api").asJsonAsync(new Callback<JsonNode>() {
  public void completed(HttpResponse<JsonNode> response) {
    responses.put(response);
    int numDone = numCompleted.incrementAndGet();
    if (numDone == 2) {
      doStuff(responses);
    }
  }
});

【讨论】：