等待一批期货完成时超时？

Question

for all tasks
  futures.add(executor.submit(new callable(task)))

现在我想让所有的期货最多等待n秒，直到全部完成。我知道我可以调用future#get(timeout)，但是如果我在循环中对我的所有期货顺序地调用它，则超时开始增加。伪代码：

for all futures
  future.get(timeout)

get块会出现超时，直到结果就绪。因此，如果第一个在超时之前完成，第二个也在超时之前完成，依此类推，则整个执行时间最多为期货数量*timeout而不是timeout。

因此，我正在寻找一个方法，它接受future的列表和一个超时，并行运行所有的结果，然后返回一个未来结果的集合。有什么想法吗？

Answer 1

您可以使用executorService.invokeAll:

执行给定的任务，返回保存所有任务完成或超时到期（以先发生者为准）时的状态和结果的期货列表。future.isdone()对于返回列表的每个元素都为true。返回时，未完成的任务被取消。请注意，已完成的任务可能已正常终止，也可能通过引发异常终止。如果在此操作进行时修改了给定的集合，则此方法的结果是未定义的。

如果您已经有需要监视的future，并且不能使用invokeall，那么您可以简单地自己测量超时。伪代码：

long endTime = System.currentTimeMillis() + timeoutMS;
for(f : futures)
    f.get(Math.max(0, endTime - System.currentTimeMillis()), TimeUnit.MILLISECONDS);