什么会导致 ExecutorService.invokeAll() 抛出 InterruptedException？

Question

javadoc 说 invokeAll(Collection<> callables) throws

InterruptedException - 如果在等待时被中断，则取消未完成的任务

但没有关于为什么呼叫会被中断的文档。我的程序会这样做——但很少发生，我无法编写会导致它发生的测试。

我正在使用没有超时的单参数方法。

public class ParallelUtil<T> {

    public interface Task<T> {
        public void execute(T data) throws Exception;
    }

    public void execute(final Task<T> task, Collection<T> targets) {
        ExecutorService executor = null;
        try {
            executor = Executors.newFixedThreadPool(20);
            execute(task, targets, executor);
        } finally {
            if (executor != null) {
                try {
                    executor.shutdown();
                } catch (Exception e) {}
            }
        }
    }

    private void execute(final Task<T> task, Collection<T> targets, ExecutorService executor) {
        List<Callable<Void>> tasks = new ArrayList<>();
        ...
        try {
            executor.invokeAll(tasks);
        } catch (Exception e) {
            // Here we get InterruptedException - for no reason?
            // With some of the tasks left undone!
        }
    }
}

从java.util.concurrent.FutureTask.awaitDone(FutureTask.java:40‌​0) 抛出（至少在某些情况下）InterruptedException

可以同时运行许多ParallelUtils（从不同的线程启动），但正如您所见，每个调用都会创建自己的ExecutorService，因此它们不应相互混淆。

（作为一个附带问题，我可以为所有调用使用共享池，而不会使 invokeAll 调用相互混淆吗？）

Answer 1

可以同时运行许多这样的 ParallelUtils（从不同的线程启动）

显然，这些线程中至少有一个被直接通过Thread.interrupt() 或通过例如间接中断。 Future.cancel(true) 或 ExecutorService.shutdownNow()。

重现此中断的示例：

class Sleep implements ParallelUtil.Task<Integer> {
  @Override
  public void execute(Integer data) throws Exception {
    Thread.sleep(Long.MAX_VALUE);
  }
}

class InterruptInvokeAll {

  public static void main(String[] args) {
    ExecutorService executorService = Executors.newFixedThreadPool(1);
    executorService.submit(
        () -> {
          ParallelUtil<Integer> parallelUtil = new ParallelUtil<>();
          parallelUtil.execute(new Sleep(), Arrays.asList(1));
        });

    executorService.shutdownNow(); // indirectly interrupts thread that calls executor.invokeAll
   }    
}

Answer 2

什么会导致ExecutorService.invokeAll() 抛出InterruptedException？

查看shutdownNow()的javadoc：

除了尽力停止处理正在执行的任务之外，没有任何保证。 例如，典型的实现将通过Thread.interrupt() 取消，因此任何未能响应中断的任务可能永远不会终止。

由于invokeAll 一直等到所有任务都完成，所以从另一个线程调用shutdownNow() 是invokeAll 调用可能被中断的一种方式。

---

但是，在代码中正如您向我们展示的那样，没有对shutdownNow() 的调用，也没有明显的方式让执行程序服务对象泄漏到另一个线程。

您的代码（或其他一些库代码）中的某些内容也可能正在调用Thread.interrupt。例如，其中一项任务可能是对自己执行此操作。