Интерфейс Condition

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

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

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

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

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

Соображения по реализации

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

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

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

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

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

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

Соображения по реализации

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

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

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

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

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

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

Метод возвращает оценку количества оставшихся наносекунд ожидания, учитывая переданное значение 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();
   }
 }

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

Соображения по реализации

Предполагается, что текущий поток держит блокировку, связанную с этим Condition, когда этот метод вызывается. Реализация должна определить, так ли это, и если нет, как на это реагировать. Обычно выбрасывается исключение (например, 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.