Java并行工作迭代器？

Question

我正在寻找一个类，可以在其中重写方法来完成工作，并像迭代器一样返回结果。像这样：

ParallelWorkIterator<Result> itr = new ParallelWorkIterator<Result>(trials,threads) {

  public Result work() {
    //do work here for a single trial...
    return answer;
  }

};
while (itr.hasNext()) {
  Result result = itr.next();
  //process result...
}

这主要将用于蒙特卡洛模拟之类的事情，但我不想每次都要处理设置线程池和管理返回线程的问题。我开设了自己的班级， 希望能
完成这个任务，但是我对此没有足够的信心，以为我会检查是否已经存在这样的东西。

编辑：明确地说，我希望它在每个工作方法返回后继续在后台运行并对结果进行排队，直到完成所有试验为止。因此，下一个方法可能会等待返回，直到队列中有结果为止。

Answer 1

看看ExecutorCompletionService。它可以满足您的所有需求。

   void solve(Executor e, Collection<Callable<Result>> solvers)
     throws InterruptedException, ExecutionException {
       //This class will hold and execute your tasks
       CompletionService<Result> ecs
           = new ExecutorCompletionService<Result>(e);
       //Submit (start) all the tasks asynchronously
       for (Callable<Result> s : solvers)
           ecs.submit(s);
       //Retrieve completed task results and use them
       int n = solvers.size();
       for (int i = 0; i < n; ++i) {
           Result r = ecs.take().get();
           if (r != null)
               use(r);
       }
   }

使用CompletionService的好处是它总是返回第一个完成的结果。这样可以确保您不等待任务完成，并且可以使未完成的任务在后台运行。