为什么要在可调用函数中设置中断位

Question

因此，该资源(http://www . IBM . com/developer works/Java/library/j-jtp 05236/index . html)建议，当线程本身不处理中断时，在线程中设置中断位，“以便调用堆栈中更高层的代码可以了解到中断，并在需要时做出响应。”

假设我正在使用执行器服务在不同的线程中运行某些内容。我构造了一个可调用的，并将这个可调用传递给执行器服务.submit（），它返回一个未来。如果可调用项被中断，然后重置中断位，则当调用 Future.get（） 时，关联的未来不会抛出中断异常。那么，如果这个未来是主线程访问生成的线程的唯一方式，那么在可调用中设置中断位的目的是什么？

class MyCallable implements Callable<String> {
  @Override
  public String call() {
    while (!Thread.currentThread().isInterrupted()) {
    }
    Thread.currentThread().interrupt();
    return "blah";
  }
}

 ExecutorService pool = makeService();
 Future<String> future = pool.submit(new MyCallable());
 // Callable gets interrupted and the Callable resets the interrupt bit.
 future.get(); // Does not thrown an InterruptedException, so how will I ever know that the Callable was interrupted?

Answer 1

中断线程应该终止它，但方式不如kill（）脆弱。仅在各种阻塞操作期间检查线程的中断状态。

如果您的线程在其中一个操作期间被中断，则会抛出InterruptedException。当这种情况发生时，您希望尽快干净地退出。那么，如果执行器服务线程中断，Callable应该怎么做？

如果其操作很短，一个有效的选项是正常完成该操作，但在线程上设置中断状态，以便在此操作完成后执行程序服务将关闭。

如果操作较长，则可能需要改为引发异常，告知调用方操作已中断。

Answer 2

在这个场景中，中断标志没有在两个线程之间传递是正确的（这就是内置ExecutorService的设计原理）。如果希望主线程看到可调用的中断状态，则必须从调用方法中抛出InterruptedException。

class MyCallable implements Callable<String> {
  @Override
  public String call() {
    // ...
    if(Thread.currentThread().isInterrupted()) {
      throw new InterruptedException();
    }
    return "blah";
  }
}

请注意，在这种情况下，您仍然不会直接从Future.get（）获取InterruptedException。因为它是由可调用对象抛出的，它将被包装在ExecutionException中（这是为了让您可以区分可调用对象的中断和主线程的中断）。