如何等待多个Callable而不阻塞get（）

Question

我正在使用java Callable和ExecutorService执行计算：

ExecutorService threadExecutor = Executors.newCachedThreadPool();
for (TaskCallable task: tasks) {
    threadExecutor.submit(task);
}

我想让任务运行最多2分钟。但如果我打电话：

task.get(2, TimeUnit.MINUTES);

然后它就会立刻封锁！不要让我为其他任务分配超时，直到超时结束。

我可以用

threadExecutor.invokeAll(tasks, 2, TimeUnit.MINUTES);

但它返回的是未来列表，我不知道什么任务属于哪个未来。

Answer 1

因为留档说：

返回：
表示任务的期货列表，其顺序与迭代器为给定任务列表生成的顺序相同，每个任务都已完成。

当你记住两件事时，这一切都会如期进行：

• 仅对具有保证顺序的集合使用invokeAll（例如ArrayList，但没有HashMap）

Answer 2

使用等待终止。来自文档：

阻塞，直到所有任务在关闭请求后完成执行，或超时发生，或当前线程中断（以先发生的为准）。

boolean awaitTermination(long timeout, TimeUnit unit)
        throws InterruptedException;