Java Future 多线程如何返回结果？

Question

我仍在学习如何在 Java 中使用 Future 和 Callable。 偶然遇到这个问题：

假设我有类：

TaskWorker implements Callable {
  public String id;
  public TaskWorker(String id) {
     this.id = id;
  }

  public Documents call() trows Exception {
       //Assume here, that Search and Doc are my own method to search and retrieve docs
       Search search =  new Search();
       Documents docResult = search.process(id);

       //think about documents has getDocs
       //docResult.getDocs() will return number of document found from search

       return docResult;
  }
}

这是主要方法：

public static void main(String[] args) {
   //assume here, that I build in request contains many Id

   Request request = new Request();
   request.process;

   ExecutorService service = Executors.newFixedThreadPool(3);
   List<Future<Documents>> result = new ArrayList<Future<Documents>>();

   for (int i=0;i<request.length;i++) {
       Callable<Documents> worker = new TaskWorker(request.getId[i]);
       Future<Documents> submit = executor.submit(worker);
       result.add(submit);
   }

   Response response = new Response();
   ArrayList<Documents> docList = new ArrayList<Documents>();

   for (Future<Documents> future:result) {
     docList.add(future.get().getDocs());
   }

   response.setDocuments(docList);
}

我想做的是，将请求的一部分分解为在单独的线程中运行，因为每个请求 Id 都是单独的搜索进程。 所以我尝试通过将结果存储在 future 对象中来利用 Java 池。

我感到困惑的是，在这种情况下未来将如何运作？ 对于每个线程完成，它会保存结果吗？在所有过程完成后，我可以循环 future 对象以获得正确的结果吗？

另外，不能保证进程会按顺序运行（1、2、3、4 等），对吧？ 如果是这样，那么如果我想将每个原始请求与未来结果相关联，最好的策略是什么？

请指教。

谢谢

Answer 1

此外，不能保证
进程将按顺序运行
（1、2、3、4 等），对吗？如果那
那么最好的策略是什么
如果我想关联每个原件
请求未来的结果？

您无法知道后台线程启动和完成的顺序，但是当您循环遍历 result-ArrayList 时，您当然会按照提交的顺序获得结果。这里唯一可能发生的事情是 .get() 将阻塞，直到该未来对象的特定结果可用（如果尚未可用）。

Answer 2

您应该创建 SynchronizedMap 并将其与请求一起传递给构造函数中的 TaskWorker。 TaskWorker 完成作业后应将 Request 和 Result 添加到映射中。

您不必循环 Futures 来获取结果，只需确保所有作业都已完成即可。