执行服务。调用所有（超时，时间单位）与未来。获取（超时，时间单位）

Question

我正在使用ExecutorService.invokeAll（Callable， timeout， TimeUnit）方法

在提交给ExecutorService的每个Callable中，我都有一个future.get（）

未来会发生什么。即使executorService已超时，get（）仍将在后台运行？

我必须指定未来的超时时间吗。获取（timeout，TimeUnit）并抛出TimeoutException，以确保未来被终止？

Answer 1

来自Javadoc

执行给定的任务，当所有任务完成或超时过期时，返回保存其状态和结果的未来列表

所以1。所有可调用的将提供所有结果，包括未来的结果。get（）内部调用，2。一旦invokeAll返回（即在超时之前），所有期货都将终止。

Answer 2

正如文件所述：

返回后，尚未完成的任务将被取消。

虽然没有明确说明，但它使用了Future。取消（true），即中断正在运行的任务。因为未来。get（）支持中断，这将通过抛出InterruptedException使其完成。如果您的Callable没有捕捉到它，也没有执行任何可能重置中断状态的操作，这意味着可调用项将在将来停止等待。get（）如果指定给invokeAll的超时已过。

但是，ainkeAll只取消未来，因此，发送中断信号，但不等待线程对其做出反应并完成Callable的代码的执行。因此，当由于超时，ainkeAll完成时，一些线程可能仍然在已经取消的任务上运行。但是，如果这些任务仅由Future::get组成，这应该不是问题。

但是，如果你只想等待现有的未来的列表的完成，那么你可以更高效地完成这项工作。毕竟，您正在将每个未来包装成一个可调用的调用未来。get，它将invokeAll包装成另一个未来，可能会在每个未来阻塞一个工作线程，然后等待所有这些未来线程的完成。最后一步正是这项任务的目的，所以你可以不用前面的步骤来完成它，例如：。

public static void waitForAll(Collection<? extends Future<?>> futures,
                              long timeout, TimeUnit unit)
    throws InterruptedException {

    long nanos = unit.toNanos(timeout);
    boolean done = false;
    try {
        final long deadline = System.nanoTime() + nanos;
        final int size = futures.size();
        for(Future<?> f: futures) {
            if(!f.isDone()) {
                if (nanos <= 0L) return;
                try { f.get(nanos, TimeUnit.NANOSECONDS); }
                catch(CancellationException | ExecutionException ignore) {}
                catch(TimeoutException toe) { return; }
                nanos = deadline - System.nanoTime();
            }
        }
        done = true;
    }
    finally { if (!done) for(Future<?> f: futures) f.cancel(true); }
}

这基本上就是AbstractExecutorService在提交了所有Callables之后等待所有期货完成的方式，为每个期货创建一个Future。如前所述，如果你想做的只是等待现有未来的列表，你可以直接这样做，而不需要通过向执行者提交作业来浪费资源。使用这种方法的另一个好处是，这将取消原始的期货，而不仅仅是取消等待期货的工作。您还可以依赖此方法中断取消，而此属性不是为invokeAll显式指定的，