Класс AbstractQueuedLongSynchronizer.ConditionObject

public class AbstractQueuedLongSynchronizer.ConditionObject
extends Object
implements Condition, Serializable

Реализация Condition для AbstractQueuedLongSynchronizer, служащая основой для реализации Lock.

Документация методов этого класса описывает механику, а не поведенческие характеристики с точки зрения пользователей Lock и Condition. Экспортированные версии этого класса, как правило, должны сопровождаться документацией, описывающей семантику условия, которая основана на семантике связанного AbstractQueuedLongSynchronizer.

Этот класс реализует Serializable, но все поля являются transient, поэтому у десериализованных условий нет ожидающих потоков.

Конструкторы

ConditionObject

public ConditionObject()

Создаёт новый ConditionObject экземпляр.

Методы

signal

public final void signal()

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

Определено в:

signal в интерфейсе Condition

Исключение:

IllegalMonitorStateException - если AbstractQueuedLongSynchronizer.isHeldExclusively() возвращает false

signalAll

public final void signalAll()

Перемещает все нити из очереди ожидания для данного условия в очередь ожидания для владеющего блокировки.

Определено в:

signalAll в интерфейсе Condition

Исключение:

IllegalMonitorStateException - если AbstractQueuedLongSynchronizer.isHeldExclusively() возвращает false

awaitUninterruptibly

public final void awaitUninterruptibly()

Реализует ожидание условия без возможности прерывания.

1. Сохранить состояние блокировки, возвращённое AbstractQueuedLongSynchronizer.getState().
2. Вызвать AbstractQueuedLongSynchronizer.release(long) со сохранённым состоянием в качестве аргумента, бросив IllegalMonitorStateException в случае неудачи.
3. Блокироваться до получения сигнала.
4. Возобновить выполнение, вызвав специализированную версию AbstractQueuedLongSynchronizer.acquire(long) со сохранённым состоянием в качестве аргумента.

Определено в:

awaitUninterruptibly в интерфейсе Condition

await

public final void await()
                 throws InterruptedException

Реализует ожидание условия с возможностью прерывания.

1. Если текущая нить прервана, бросить InterruptedException.
2. Сохранить состояние блокировки, возвращённое AbstractQueuedLongSynchronizer.getState().
3. Вызвать AbstractQueuedLongSynchronizer.release(long) со сохранённым состоянием в качестве аргумента, бросив IllegalMonitorStateException в случае неудачи.
4. Блокироваться до получения сигнала или прерывания.
5. Возобновить выполнение, вызвав специализированную версию AbstractQueuedLongSynchronizer.acquire(long) со сохранённым состоянием в качестве аргумента.
6. Если нить прервана во время ожидания на шаге 4, бросить InterruptedException.

Определено в:

await в интерфейсе Condition

Исключение:

InterruptedException - если текущая нить прервана (и прерывание приостановки нити поддерживается)

awaitNanos

public final long awaitNanos(long nanosTimeout)
                      throws InterruptedException

Реализует ожидание условия с ограничением по времени.

1. Если текущая нить прервана, бросить InterruptedException.
2. Сохранить состояние блокировки, возвращённое AbstractQueuedLongSynchronizer.getState().
3. Вызвать AbstractQueuedLongSynchronizer.release(long) со сохранённым состоянием в качестве аргумента, бросив IllegalMonitorStateException в случае неудачи.
4. Блокироваться до получения сигнала, прерывания или истечения времени ожидания.
5. Возобновить выполнение, вызвав специализированную версию AbstractQueuedLongSynchronizer.acquire(long) со сохранённым состоянием в качестве аргумента.
6. Если нить прервана во время ожидания на шаге 4, бросить InterruptedException.

Определено в:

awaitNanos в интерфейсе Condition

Параметры:

nanosTimeout - максимальное время ожидания в наносекундах

Возвращает:

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

Исключение:

InterruptedException - если текущая нить прервана (и прерывание приостановки нити поддерживается)

awaitUntil

public final boolean awaitUntil(Date deadline)
                         throws InterruptedException

Реализует ожидание условия с абсолютным ограничением по времени.

1. Если текущая нить прервана, бросить InterruptedException.
2. Сохранить состояние блокировки, возвращённое AbstractQueuedLongSynchronizer.getState().
3. Вызвать AbstractQueuedLongSynchronizer.release(long) со сохранённым состоянием в качестве аргумента, бросив IllegalMonitorStateException в случае неудачи.
4. Блокироваться до получения сигнала, прерывания или истечения времени ожидания.
5. Возобновить выполнение, вызвав специализированную версию AbstractQueuedLongSynchronizer.acquire(long) со сохранённым состоянием в качестве аргумента.
6. Если нить прервана во время ожидания на шаге 4, бросить InterruptedException.
7. Если время ожидания истекло во время ожидания на шаге 4, вернуть false, иначе true.

Определено в:

awaitUntil в интерфейсе Condition

Параметры:

deadline - абсолютное время ожидания

Возвращает:

false если срок истек при возвращении, иначе true

Исключение:

InterruptedException - если текущая нить прервана (и прерывание приостановки нити поддерживается)

await

public final boolean await(long time,
                           TimeUnit unit)
                    throws InterruptedException

Реализует ожидание условия с ограничением по времени.

1. Если текущая нить прервана, бросить InterruptedException.
2. Сохранить состояние блокировки, возвращённое AbstractQueuedLongSynchronizer.getState().
3. Вызвать AbstractQueuedLongSynchronizer.release(long) со сохранённым состоянием в качестве аргумента, бросив IllegalMonitorStateException в случае неудачи.
4. Блокироваться до получения сигнала, прерывания или истечения времени ожидания.
5. Возобновить выполнение, вызвав специализированную версию AbstractQueuedLongSynchronizer.acquire(long) со сохранённым состоянием в качестве аргумента.
6. Если нить прервана во время ожидания на шаге 4, бросить InterruptedException.
7. Если время ожидания истекло во время ожидания на шаге 4, вернуть false, иначе true.

Определено в:

await в интерфейсе Condition

Параметры:

time - максимальное время ожидания

unit - единица измерения времени для аргумента time

Возвращает:

false если время ожидания истекло до возврата из метода, иначе true

Исключение:

InterruptedException - если текущая нить прервана (и прерывание приостановки нити поддерживается)

hasWaiters

protected final boolean hasWaiters()

Определяет, ожидают ли какие-либо нити на этом условии. Реализует AbstractQueuedLongSynchronizer.hasWaiters(ConditionObject).

Возвращает:

true если есть ожидающие нити

Исключение:

IllegalMonitorStateException - если AbstractQueuedLongSynchronizer.isHeldExclusively() возвращает false

getWaitQueueLength

protected final int getWaitQueueLength()

Возвращает оценку числа нитей, ждущих на этом условии. Реализует AbstractQueuedLongSynchronizer.getWaitQueueLength(ConditionObject).

Возвращает:

приблизительное количество ожидающих нитей

Исключение:

IllegalMonitorStateException - если AbstractQueuedLongSynchronizer.isHeldExclusively() возвращает false

getWaitingThreads

protected final Collection<Thread> getWaitingThreads()

Возвращает коллекцию, содержащую нити, которые могут ожидать на этом условии. Реализует AbstractQueuedLongSynchronizer.getWaitingThreads(ConditionObject).

Возвращает:

коллекцию нитей

Исключение:

IllegalMonitorStateException - если AbstractQueuedLongSynchronizer.isHeldExclusively() возвращает false