java - 如何使用 Unirest 等待所有异步 REST 调用完成？

Question

作为异步编程的新手，我想知道如何等待所有 futures 完成？

在我当前的用例中，我必须读取文件并使用 JSON post 将内容逐行发布到 REST Web 服务。但是当我以正常方式执行此操作时，程序会在所有 Futures 完成之前就存在。

下面是程序的一些代码。

while ((line = br.readLine()) != null) {
    Future<HttpResponse<String>> future = Unirest.post("http://www.dummy.net")
        .fields(map)
        .asStringAsync(new Callback<String>() {
            public void completed(HttpResponse<String> response) {
                int code = response.getStatus();
            }

            public void failed(UnirestException e) {
                System.out.println("The request has failed");
            }

            public void cancelled() {
                System.out.println("The request has been cancelled");
            }
        }
    );
}

此代码在所有 Futures 完成之前运行并存在。关于如何等待所有 future 完成的任何提示？

Answer 1

将所有这些 Futures 收集起来，例如数组列表。并把它们全部拿走。

List<Future> futures = ...
// your while loop

    foreach(Future f : futures) f.get();