ExecutorService.invokeAll与关机

Question

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

由于日志记录，我知道我的每一个任务都完成了。然而，当我等于执行器的线程数时，仍然阻塞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方法：

公开列表shutdownNow() {.checkShutdownAccess()；advanceRunState(停止)；interruptWorkers()；任务= drainQueue()；.}

唯一要做的就是中断工作线程，并从工作队列中删除其余的运行表，请参阅drainQueue。Shutdown not /关机不修改invokeAll方法中的期货

因此，在我的例子中，对于一个具有N个线程的执行器，我调用300个作业，每个作业花费超过1分钟，5秒后我取消(中断工作线程)，N个线程被中断(0到N-1)。其余的未来会发生什么？Nothing，下一个对f.get()的调用(见问题中相应的行)将阻塞，您就被困在那里了。这解释了为什么我总是在I=多个线程上被阻塞。