Интерфейс Condition

Блокировка, связанная с этим условием, атомарно освобождается, и текущий поток отключается от планирования потоков и находится в спящем режиме, пока не произойдёт одно из четырёх событий:

• Другой поток вызывает метод signal() для этого условия, и текущий поток выбирается для пробуждения; или
• Другой поток вызывает метод signalAll() для этого условия; или
• Другой поток прерывает текущий поток, и прерывание приостановки потока поддерживается; или
• Происходит «ложное пробуждение».

Во всех случаях, прежде чем метод сможет вернуть результат, текущий поток должен повторно получить блокировку, связанную с этим условием. Когда поток возвращается, он гарантированно держит эту блокировку.

Если у текущего потока:

• статус прерывания установлен при входе в этот метод; или
• происходит прерывание во время ожидания, и прерывание приостановки потока поддерживается,

Рекомендации по реализации

Предполагается, что текущий поток владеет блокировкой, связанной с этим условием, когда вызывается этот метод. Реализация должна определить, так ли это на самом деле, и если нет, то как реагировать. Обычно выбрасывается исключение (такое как IllegalMonitorStateException), и реализация должна это задокументировать.

Реализация может отдавать приоритет обработке прерывания по сравнению с нормальным возвратом метода в ответ на сигнал. В этом случае реализация должна гарантировать, что сигнал перенаправляется другому ожидающему потоку, если таковой есть.

Блокировка, связанная с этим условием, атомарно освобождается, и текущий поток отключается от планирования потоков и находится в спящем режиме, пока не произойдёт одно из трёх событий:

• Другой поток вызывает метод signal() для этого условия, и текущий поток выбирается для пробуждения; или
• Другой поток вызывает метод signalAll() для этого условия; или
• Происходит «ложное пробуждение».

Во всех случаях, прежде чем метод сможет вернуть результат, текущий поток должен повторно получить блокировку, связанную с этим условием. Когда поток возвращается, он гарантированно держит эту блокировку.

Если у текущего потока установлен статус прерывания при входе в этот метод или он прерывается во время ожидания, он продолжит ожидание до получения сигнала. После возврата из этого метода статус прерывания останется установленным.

Рекомендации по реализации

Предполагается, что текущий поток владеет блокировкой, связанной с этим условием, когда вызывается этот метод. Реализация должна определить, так ли это на самом деле, и если нет, то как реагировать. Обычно выбрасывается исключение (такое как IllegalMonitorStateException), и реализация должна это задокументировать.

Блокировка, связанная с этим условием, атомарно освобождается, и текущий поток отключается от планирования потоков и находится в спящем режиме, пока не произойдёт одно из пяти событий:

• Другой поток вызывает метод signal() для этого условия, и текущий поток выбирается для пробуждения; или
• Другой поток вызывает метод signalAll() для этого условия; или
• Другой поток прерывает текущий поток, и прерывание приостановки потока поддерживается; или
• Истекает указанное время ожидания; или
• Происходит «ложное пробуждение».

Во всех случаях, прежде чем метод сможет вернуть результат, текущий поток должен повторно получить блокировку, связанную с этим условием. Когда поток возвращается, он гарантированно держит эту блокировку.

Если у текущего потока:

• статус прерывания установлен при входе в этот метод; или
• происходит прерывание во время ожидания, и прерывание приостановки потока поддерживается,

Метод возвращает оценку количества оставшихся наносекунд до ожидания, учитывая предоставленное значение nanosTimeout при возврате, или значение меньше или равно нулю, если ожидание истекло. Это значение можно использовать для определения, необходимо ли и как долго повторно ждать в случаях, когда метод возвращает результат, но ожидаемое условие всё ещё не выполнено. Типичное использование этого метода выглядит следующим образом:

 
 boolean aMethod(long timeout, TimeUnit unit)
     throws InterruptedException {
   long nanosRemaining = unit.toNanos(timeout);
   lock.lock();
   try {
     while (!conditionBeingWaitedFor()) {
       if (nanosRemaining <= 0L)
         return false;
       nanosRemaining = theCondition.awaitNanos(nanosRemaining);
     }
     // ...
     return true;
   } finally {
     lock.unlock();
   }
 }

Примечание к проекту: Этот метод требует аргумент в наносекундах, чтобы избежать ошибок усечения при отслеживании оставшегося времени. Такая потеря точности затруднила бы программистам обеспечение того, чтобы общее время ожидания не было систематически короче заданного, когда происходят повторные ожидания.

Рекомендации по реализации

Предполагается, что текущий поток владеет блокировкой, связанной с этим условием, когда вызывается этот метод. Реализация должна определить, так ли это на самом деле, и если нет, то как реагировать. Обычно выбрасывается исключение (такое как IllegalMonitorStateException), и реализация должна это задокументировать.

Реализация может отдавать приоритет обработке прерывания по сравнению с нормальным возвратом метода в ответ на сигнал или по сравнению с указанием истечения указанного времени ожидания. В любом случае реализация должна гарантировать, что сигнал перенаправляется другому ожидающему потоку, если таковой есть.

 awaitNanos(unit.toNanos(time)) > 0

Связанный с этим условием замок атомарно освобождается, и текущий поток отключается от планирования потоков и находится в спящем состоянии, пока не произойдёт одно из пяти событий:

• Другой поток вызывает метод signal() для этого Condition и текущий поток выбирается как поток, который должен быть разбужен; или
• Другой поток вызывает метод signalAll() для этого Condition; или
• Другой поток прерывает текущий поток, и прерывание приостановки потока поддерживается; или
• Установленный срок истекает; или
• Происходит «ложное пробуждение».

Во всех случаях, прежде чем этот метод сможет вернуть результат, текущий поток должен повторно получить замок, связанный с этим условием. Когда поток возвращается, он гарантированно владеет этим замком.

Если текущий поток:

• имеет установленный флаг прерывания при входе в этот метод; или
• прерывается во время ожидания и прерывание приостановки потока поддерживается,

Значение возврата указывает, истек ли срок, что можно использовать следующим образом:

 
 boolean aMethod(Date deadline)
     throws InterruptedException {
   boolean stillWaiting = true;
   lock.lock();
   try {
     while (!conditionBeingWaitedFor()) {
       if (!stillWaiting)
         return false;
       stillWaiting = theCondition.awaitUntil(deadline);
     }
     // ...
     return true;
   } finally {
     lock.unlock();
   }
 }

Рекомендации по реализации

Предполагается, что текущий поток владеет замком, связанным с этим Condition при вызове этого метода. Реализация должна определить, действительно ли это так, и если нет, как реагировать. Обычно выбрасывается исключение (например, IllegalMonitorStateException), и реализация должна это задокументировать.

Реализация может отдавать предпочтение обработке прерывания перед обычным возвратом метода в ответ на сигнал или перед указанием истечения установленного срока. В любом случае реализация должна гарантировать, что сигнал перенаправляется другому ожидающему потоку, если такой есть.

Если какие-либо потоки ожидают этого условия, то один выбирается для пробуждения. Этот поток должен повторно получить замок перед возвратом из await.

Рекомендации по реализации

Реализация может (и обычно это делает) требовать, чтобы текущий поток владел замком, связанным с этим Condition при вызове этого метода. Реализации должны задокументировать это предварительное условие и любые действия, выполняемые, если замок не владет. Обычно выбрасывается исключение, например, IllegalMonitorStateException.

Если какие-либо потоки ожидают этого условия, то все они разбуживаются. Каждый поток должен повторно получить замок перед возвратом из await.

Рекомендации по реализации

Реализация может (и обычно это делает) требовать, чтобы текущий поток владел замком, связанным с этим Condition при вызове этого метода. Реализации должны задокументировать это предварительное условие и любые действия, выполняемые, если замок не владет. Обычно выбрасывается исключение, например, IllegalMonitorStateException.