executorService的invokeAll方法中的阻塞是什么意思？ [复制]

Question

据说invokeAll是在我们想要等待所有任务完成时使用的，而不是提交或执行不等待。

完成任务是什么意思。这是否意味着产生所有其他线程的父线程卡在该点，直到所有线程返回？

Answer 1

见javadoc

<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
                          throws InterruptedException 

这是否意味着产生所有其他线程的父线程卡在该点，直到所有线程返回？

是的，你是对的！请参见下面的代码，这是来自 AbstractExecutorService.java（oracle JDK8）的 invokeAll 的实现。更重要的是，您需要注意那里的 For 循环。我们检查 if (!f.isDone()) ，这意味着如果任务没有完成（完成）进入循环并调用 f.get()，这是阻塞调用。实际上，您的 invokeAll 调用者将被阻塞，直到所有任务都未完成。

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 {
        for (Callable<T> t : tasks) {
            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()) {
                try {
                  f.get();
                } catch (CancellationException ignore) {
                } catch (ExecutionException ignore) {
                }
            }
        }
        done = true;
        return futures;
    } finally {
        if (!done)
            for (int i = 0, size = futures.size(); i < size; i++)
                futures.get(i).cancel(true);
    }
}