Pure 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(), и если он вернет проверку, чтобы проверить, действительно ли время истекло.

В действительности, я думаю, что вы можете достичь вышеизложенного с помощью классов java.util.concurrent. Взгляните на класс Lock.

Answer 2

Ответ Майка К. является тем, который вы хотите. Но чтобы заставить ваш код работать, сделайте sleeping volatile и удалите синхронизацию с abortDelay. Тогда ваша единственная проблема заключается в том, что abortDelay может поймать delay непосредственно перед любой линией sleeping = false;. Поэтому после обеих строк вызовите 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(); 
    } 
}