java - Java Futures 的乱序返回

Question

我可以想出的唯一模型来运行多个相似的进程(SIMD)使用Java Futures ( java.util.concurrent.Future<T> ) 如下:

class Job extends Callable<T> {
  public T call() {
    // ...
  }
}
List<Job> jobs = // ...
List<Future<T>> futures = ExecutorService.invokeAll(jobs);
for (Future<T> future : futures) {
  T t = future.get();
  // Do something with t ...
}

此模型的问题在于，如果作业 0 需要很长时间才能完成，但作业 1、2 和 3 已经完成，则 for循环将等待从作业 0 获取返回值。

有没有什么模型可以让我得到每个 Future无需调用 Future.isDone() 即可获得结果并忙于等待(或调用 Thread.sleep())，如果还没有准备好？

Answer 1

您可以试用ExecutorCompletionService:

http://download.oracle.com/javase/1.5.0/docs/api/java/util/concurrent/ExecutorCompletionService.html

您只需提交您的任务并调用 take，直到您收到所有 Futures。