因此，我有一些对中断敏感的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吗？我猜不是，毕竟他们是同一班人。为什么只有当i =执行程序的线程数时，它才会被阻塞？
最佳答案
是的，您不应该在关闭状态下使用invokeAll。至少这是我的理解，如果我错了，请纠正我。
shutdownNow方法：
public List<Runnable> shutdownNow() {
...
checkShutdownAccess();
advanceRunState(STOP);
interruptWorkers();
tasks = drainQueue();
...
}
唯一要做的是中断工作线程，并从工作队列中删除其余可运行对象，请参阅drainQueue。 ShutdownNow / Shutdown不会在我们的invokeAll方法中修改期货
因此，在我的情况下，对于具有N个线程的Executor，我调用300个作业，每个作业花费1分钟以上，在5秒钟后我取消（中断工作线程）后，N个线程被中断（0至N-1） ）。其余期货会怎样？没什么，对f.get（）的下一次调用（请参阅问题中的相应行）将不会阻塞，您将无法使用。这解释了为什么我总是在i =线程数上受阻。
关于java - ExecutorService.invokeAll和关闭，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/27254073/