java - ExecutorService.invokeAll 和关闭

Question

所以我有一些可调用的任务，对中断敏感，我使用 invokeAll 将其提交给 ExecutorService。 5 秒后，我从另一个方法调用 executorService.shutdownNow，然后调用awaitTermination，它返回 true，所以一切看起来都很好。问题是执行器永远不会终止。

通过日志记录，我知道我的每一项任务都已完成。 然而，当 i 等于执行器的线程数时，invokeAll 仍然在 f.get 上阻塞:

以下代码是从 AbstractExecutorService 获取的 +一些日志记录。

        @Override
    public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) throws InterruptedException {
        if (tasks == null) throw new NullPointerException();
        ArrayList<Future<T>> futures = new ArrayList<Future<T>>(tasks.size());
        boolean done = false;
        try {
            List<Callable<T>> list = new ArrayList<Callable<T>>();
            for (Callable<T> t : tasks) {
                list.add(t);
                RunnableFuture<T> f = newTaskFor(t);
                futures.add(f);
                execute(f);
            }
            for (int i = 0, size = futures.size(); i < size; i++) {
                Future<T> f = futures.get(i);
                if (!f.isDone()) {
                    log.info("Future %s is not done!. Task %s", i, list.get(i));
                    try {
                        log.info("Get from future %s", i);
                        // NEXT LINE BLOCKS FOR i= NUMBER OF THREADS
                        f.get();
                        log.info("Got result from future %s", i);
                    } catch (CancellationException ignore) {
                    } catch (ExecutionException ignore) {
                    }
                }
            }
            log.info("Obtained all!");
            done = true;
            return futures;
        } finally {
            if (!done) for (int i = 0, size = futures.size(); i < size; i++)
                futures.get(i).cancel(true);
        }
    }

我不应该在关闭时使用invokeAll吗？我想不会吧，毕竟他们是同一个类的。为什么只有当i=执行器的线程数时才会被阻塞？

Answer 1

是的，您不应该在关闭时使用 invokeAll。至少我是这么理解的，如有错误请指正。

• shutdownNow 方法:

public List<Runnable> shutdownNow() {
...
        checkShutdownAccess();
        advanceRunState(STOP);
        interruptWorkers();
        tasks = drainQueue();
...
}

唯一要做的就是中断工作线程并从工作队列中删除其余的可运行对象，请参阅drainQueue。 ShutdownNow/Shutdown 不会修改我们的 invokeAll 方法中的 future

所以在我的例子中发生的情况是，对于一个有 N 个线程的 Executor，我调用了 300 个作业，每个作业都需要 1 分钟以上，5 秒后我取消(中断工作线程)，N 个线程被中断(>0 到 N-1)。其余的 future 会怎样？ 什么都没有，下一次对 f.get() 的调用(请参阅问题中的相应行)将被阻止，并且您会被困在那里。这解释了为什么我总是在 i = 线程数上被阻塞。