Java：从代码中调用可中断方法

Question

我正在阅读《Java并发实践》第七章。

在讨论没有自己的取消策略但调用可以中断的方法的部分中，本书有以下内容要说。

不支持取消但仍调用可中断的活动 阻塞方法必须在循环中调用它们，然后重试 检测到中断。在这种情况下，他们应该保存 本地中断状态并在返回前恢复， 而不是立即捕获 InterruptedException。

我还没有完全理解这一点。

这是否意味着，如果我在方法中调用 Thread.sleep ，我将不得不在循环中调用它或其他什么？

谁能解释为什么应该这样做？

Answer 1

我在我的方法中调用 Thread.sleep，我必须在循环中调用它或其他什么？

当当前线程（被另一个线程）中断时，Thread.sleep() 将抛出 InterruptedException。如何对此做出反应是你的选择。如果你想睡觉，不管是否有人试图打扰你，那么是的，你必须围绕 try-catch 块构建某种循环。也许您应该使用时钟（例如 System.nanoTime() ）来检查在抛出异常之前您睡了多长时间，然后继续睡眠剩余时间等。

请注意，InterruptedException仅当另一个线程通过调用(current)Thread.interrupt() 中断了当前线程时，才会抛出。它不会自行发生，因此通常您不需要围绕睡眠或类似的事情构建任何循环。通常线程只有在有充分理由时才会被中断（例如应用程序关闭），因此您可能希望支持取消/中断，除非没有特殊原因不这样做。例如，“特殊原因”可能是写入 I/O 设备并尝试保证所有数据都将被写入，而不管取消尝试如何。

Answer 2

首先解释一下：

线程的中断状态基本上是一个布尔标志，通过 interrupt() 将其设置为“true”。
该标志的当前状态可以使用Thread.currentThread().isInterrupted()读取。

如果可中断操作（例如 Object.wait() 或 Thread.sleep()）发现已设置中断标志
它将抛出一个 InterruptedException，同时清除（设置为“false”）该标志，它可能如下所示：

if ( Thread.interrupted() ) { throw new InterruptedException(); }

注意并记住 Thread. Interrupted() 隐式清除中断标志！
这意味着，当执行 catch( InterruptedException ie) {...} 时，
线程本身不知道它被中断了。

也就是说，让我们看两个示例：

第一个是支持取消的任务示例。
在这里，我们并不真正关心任务在中止之前进行了多远：

  public void run() {

    int x = 0;

    try {

      while (x < 10) {
        Thread.sleep(1000); // Some interruptible operation
        x++;
      }

      System.out.println("x = " + x);

    } catch (InterruptedException ie) {

      System.out.println("Interrupted: x = " + x);

      // We know we've been interrupted. 
      // Let the caller know it, too:
      Thread.currentThread().interrupt();
    }

  }

此代码尝试将 x 从 0 计数到 10。如果不被中断，它将完成并输出“x = 10”。
但是，如果线程在中间被中断，则会抛出 InterruptedException，从而中止正在进行的递增 x 的任务。
在这种情况下，输出可能是从“Interrupted: x = 0”到“Interrupted: x = 9”的任何内容，具体取决于线程被中断的时间。

请注意，在退出之前恢复线程的中断标志被认为是很好的做法，因为
否则，此 run() 方法的调用者将看不到中断状态。

现在，如果我们的任务完整执行至关重要，以便输出始终为“x = 10”，这意味着该任务不支持取消，我们需要另一种方法：

  public void run() {
    int x = 0;

    boolean wasInterrupted = false; // <- This is the local variable to store the interruption status

    while (x < 10) {

      wasInterrupted = wasInterrupted || Thread.interrupted(); // not really needed in this case, but for the sake of completeness...

      try {

        Thread.sleep(1000); // <- Some interruptible operation

      } catch (InterruptedException e) {
        wasInterrupted = true;
      }

      x++;
    }

    System.out.println("x = " + x);

    if ( wasInterrupted ) {
      Thread.currentThread().interrupt();
    }

  }

在这种情况下，即使在 < code>InterruptedException 直到任务完成。
为了保持友好，如果我们检测到中断，我们会将该条件存储在 wasInterrupted 中，以便我们可以
从方法返回之前正确设置中断标志。

这就是这个意思

应该在本地保存中断状态并在返回之前恢复它。

它说“应该”，因为我们并不严格要求以这种方式处理中断 - 我们也可以忽略任何 InterruptedException
完成我们的任务，然后返回。但这不是上面提到的好做法，并且在某些情况下可能会引起麻烦。

Answer 3

据我了解：一个长时间运行的服务，其本身不能或不应该被中断，正在调用其他可以被中断的方法。因此，这个长时间运行的服务应该能够检测到这一点并通过方法或标志报告它。但它应该能够再次尝试该操作，而不是仅仅抛出 InterruptedException。

调用阻塞方法意味着当前执行被阻塞并等待，直到阻塞方法返回一个值。这可以循环完成。然后您就知道方法调用是否成功或者调用的方法是否被中断。

Answer 4

我没有这本书。但据我了解，如果一个活动中断（顺便说一下，睡眠不是一个中断信号。但是您可以通过中断信号将线程从睡眠状态唤醒），该活动需要保存其当前的动态数据（中断状态）以便恢复自身并从之前的状态恢复。例如;

//Let's say you have integer data named "a"...
a = 45646;

//Normally after interruption, and terminating the activity data a is currently
//referencing @memory will be released...

//If you want to continue using data in a you have to save it somewhere
// persistant(Let's say a file)
void onInterruptionDetected()
{
    saveToSomeFile(a, "temp.txt");
}

//After re-execution of activity(Assuming we need a's previous data in order to 
// continue...), we can recover a's data(which is 45646) in previous interruption...
void onResumeDetected()
{
    a = loadFromFile("temp.txt")
}

希望这会有所帮助，我仍然很困，可能有错误:)