ExecutorService.invokeAll并关闭

所以我有一些Callable任务， 对中断很敏感 ，我使用invokeAll提交给ExecutorService。 从另一个方法5秒钟后，我调用executorService.shutdownNow，之后我调用awaitTermination，它返回true，所以一切似乎都很好。 问题是执行者永远不会终止。

由于记录，我知道我的每个任务都完成了。 不过，当我等于执行程序的线程数时，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？ 毕竟他们都在同一个班级，我想不是。 为什么它会被阻止，只有当我=执行器的线程数量？

---

是的，你不会在关机时使用invokeAll 。 至少这是我的理解，如果我错了，请纠正我。

shutdownNow方法：

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

唯一的问题是中断工作线程并从工作队列中删除其余的runnables，请参阅drainQueue。 ShutdownNow / Shutdown不会修改invokeAll方法中的期货

因此，对我而言，对于一个具有N个线程的执行程序，我调用300个作业，每个作业占用超过1分钟，5秒后取消（中断工作线程），N个线程中断（ 0到N-1 ）。 期货的其余部分会发生什么？ 没有什么 ，下一次调用f.get（）（请参阅问题中的相应行）将会阻塞，并且您卡在那里。 这解释了为什么我总是阻止我=线程数。

链接地址: http://www.djcxy.com/p/50185.html

上一篇: ExecutorService.invokeAll and shutdown

下一篇: why all Future.get() throwing CancelleationException in invokeAll with timeout