纯Java：我怎么知道我的线程是否在休眠？

Question

我有一个线程可以做几件事。其中之一就是只睡一段时间。 正常睡眠后它会调用delayFinished() 方法，但如果睡眠被中断，则不应调用delayFinished()。我还需要一个中止睡眠的方法，它可能被其他线程调用。

所以这是捕捉我意图的实现，但我认为它不会起作用：

public class MyThread extends Thread {
   private boolean sleeping=false;
   private Object sleepingControl=new Object();

   //... other unrelated stuff...

   private void delay() {
      try {
          synchronized(sleepingControl) {
             sleeping=true;         
             sleep(delay);
             sleeping=false;                        
             delayFinished();
          }
      } catch (InterruptedException e) {
          sleeping=false;
      }
    }
    public void abortDelay() {
          synchronized(sleepingControl) {
             if (sleeping)          
                interrupt();
          }
    }
 }

如果delay() 被调用，并且在它处于睡眠状态时，abortDelay() 被另一个线程调用（主要用例），abortDelay() 将挂在同步语句上，因为delay() 的调用者拥有该监视器并且还没放弃呢。

另一方面，如果延迟是这样实现的：

   private void delay() {
      synchronized(sleepingControl) {
         sleeping=true;         
      }
      try {              
             sleep(delay);

可能是delay()被调用，完成同步块设置 睡眠为真，但随后调用abortDelay()，它会调用interrupt() 即使线程尚未开始睡眠。

任何人都可以对这些尝试提出任何改进建议吗？

Answer 1

您需要调查 Object.wait()/notify() 而不是使用 sleep()。使用 wait() 的关键之一是它释放对象上的锁，同时等待允许另一个线程获取锁并使用 notify() 将其唤醒。

例如

public class MyThread extends Thread {
   private boolean aborted = false;
   private final Object sleepingControl=new Object();

   //... other unrelated stuff...

   private void delay() {
      try {
          synchronized(sleepingControl) {
             sleepingControl.wait(delay);

             if (!aborted)
                 delayFinished();
          }
      } catch (InterruptedException e) {
      }
    }
    public void abortDelay() {
          synchronized(sleepingControl) {
             aborted = true;
             sleepingControl.notify();
          }
    }
 }

这也不是全部，因为 wait() 有一个奇怪的实现怪癖，它可以虚假地唤醒。所以你需要手动循环 wait() 调用，如果它返回检查时间是否真的过期了。

实际上，我认为您可以使用java.util.concurrent 类更简单地实现上述目标。看看Lock 类。

Answer 2

Mike Q. 的答案是您想要的答案。但要使您的代码正常工作，请将sleeping 设为易失性并从abortDelay 中删除同步。那么你唯一的问题是abortDelay 可能会在任何一行sleeping = false; 之前立即捕获delay。所以在这两行之后，调用interrupted() 清除可能的设置。

更正/详细说明： abortDelay 需要同步。代码应如下所示：

private final Object     sleepingControl = new Object();
private volatile boolean sleeping;

private void delay() {
    try {
        sleeping=true;  // Synching not needed.
        sleep(delay);
        // Thread COULD be interrupted at this point!
        // Now makes sure abortDelay sees this change.
        synchronized (sleepingControl)  {
            sleeping = false;
            // Thread can no longer be interrupted.
            // Clear flag if it is set.
            interrupted();
        }
        delayFinished();
    }
    catch (InterruptedException e) {
        // Thread COULD be interrupted at this point!
        synchronized (sleepingControl)  {
            sleeping = false;
            // Thread can no longer be interrupted.
            // Clear flag if it is set.
            interrupted();
        }
    }
}
public void abortDelay() {
    synchronized (sleepingControl)  {
        if (sleeping)
            // At this point, "sleeping" HAS to be true.
            interrupt();
    }
}