Класс AbstractQueuedLongSynchronizer

public AbstractQueuedLongSynchronizer()

protected final long getState()

Возвращает:

текущее значение состояния

protected final void setState(long newState)

Параметры:

newState - новое значение состояния

protected final boolean compareAndSetState(long expect, long update)

Параметры:

expect - ожидаемое значение

update - новое значение

Возвращает:

true в случае успеха. Возврат False указывает, что фактическое значение не было равно ожидаемому значению.

protected boolean tryAcquire(long arg)

Параметры:

arg - аргумент приобретения. Это значение всегда передаётся методу acquire или сохраняется при входе в ожидание условия. Значение в противном случае не интерпретируется и может представлять собой что угодно.

Возвращает:

true в случае успеха. При успехе этот объект был приобретён.

Исключения:

IllegalMonitorStateException - если приобретение поставит этот синхронизатор в незаконное состояние. Это исключение должно выбрасываться последовательным образом для корректной работы синхронизации.

UnsupportedOperationException - если эксклюзивный режим не поддерживается

protected boolean tryRelease(long arg)

Параметры:

arg - аргумент освобождения. Это значение всегда передаётся методу release или текущее значение состояния при входе в ожидание условия. Значение в противном случае не интерпретируется и может представлять собой что угодно.

Возвращает:

true, если этот объект теперь находится в полностью освобождённом состоянии, так что любые ожидающие потоки могут попытаться приобрести; и false в противном случае.

Исключения:

IllegalMonitorStateException - если освобождение поставит этот синхронизатор в незаконное состояние. Это исключение должно выбрасываться последовательным образом для корректной работы синхронизации.

UnsupportedOperationException - если эксклюзивный режим не поддерживается

protected long tryAcquireShared(long arg)

Параметры:

arg - аргумент приобретения. Это значение всегда передаётся методу acquire или сохраняется при входе в ожидание условия. Значение в противном случае не интерпретируется и может представлять собой что угодно.

Возвращает:

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

Исключения:

IllegalMonitorStateException - если приобретение поставит этот синхронизатор в незаконное состояние. Это исключение должно выбрасываться последовательным образом для корректной работы синхронизации.

UnsupportedOperationException - если совместный режим не поддерживается

protected boolean tryReleaseShared(long arg)

Параметры:

arg - аргумент освобождения. Это значение всегда передаётся методу release или текущее значение состояния при входе в ожидание условия. Значение в противном случае не интерпретируется и может представлять собой что угодно.

Возвращает:

true, если это освобождение совместного режима может позволить ожидающему приобретению (совместному или эксклюзивному) преуспеть; и false в противном случае

Исключения:

IllegalMonitorStateException - если освобождение поставит этот синхронизатор в незаконное состояние. Это исключение должно выбрасываться последовательным образом для корректной работы синхронизации.

UnsupportedOperationException - если совместный режим не поддерживается

protected boolean isHeldExclusively()

Возвращает:

true, если синхронизация удерживается исключительно; false в противном случае

Исключения:

UnsupportedOperationException - если условия не поддерживаются

public final void acquire(long arg)

Параметры:

arg - аргумент приобретения. Это значение передаётся tryAcquire(long), но в противном случае не интерпретируется и может представлять собой что угодно.

public final void acquireInterruptibly(long arg) throws InterruptedException

Параметры:

arg - аргумент приобретения. Это значение передаётся tryAcquire(long), но в противном случае не интерпретируется и может представлять собой что угодно.

Исключения:

InterruptedException - если текущий поток прерван

public final boolean tryAcquireNanos(long arg, long nanosTimeout) throws InterruptedException

Parameters:

arg - аргумент приобретения. Это значение передаётся в tryAcquire(long), но в противном случае не интерпретируется и может представлять собой что угодно.

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

Returns:

true если получено; false если таймаут истек

Throws:

InterruptedException - если текущий поток прерван

public final boolean release(long arg)

Parameters:

arg - аргумент освобождения. Это значение передаётся в tryRelease(long), но в противном случае не интерпретируется и может представлять собой что угодно.

Returns:

значение, возвращённое из tryRelease(long)

public final void acquireShared(long arg)

Parameters:

arg - аргумент приобретения. Это значение передаётся в tryAcquireShared(long), но в противном случае не интерпретируется и может представлять собой что угодно.

public final void acquireSharedInterruptibly(long arg) throws InterruptedException

Parameters:

arg - аргумент приобретения. Это значение передаётся в tryAcquireShared(long), но в противном случае не интерпретируется и может представлять собой что угодно.

Throws:

InterruptedException - если текущий поток прерван

public final boolean tryAcquireSharedNanos(long arg, long nanosTimeout) throws InterruptedException

Parameters:

arg - аргумент приобретения. Это значение передаётся в tryAcquireShared(long), но в противном случае не интерпретируется и может представлять собой что угодно.

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

Returns:

true если получено; false если таймаут истек

Throws:

InterruptedException - если текущий поток прерван

public final boolean releaseShared(long arg)

Parameters:

arg - аргумент освобождения. Это значение передаётся в tryReleaseShared(long), но в противном случае не интерпретируется и может представлять собой что угодно.

Returns:

значение, возвращённое из tryReleaseShared(long)

public final boolean hasQueuedThreads()

Returns:

true если могут быть другие потоки, ожидающие приобретения

public final boolean hasContended()

Returns:

true если когда-либо было столкновение

public final Thread getFirstQueuedThread()

Returns:

первый (самый долго ожидающий) поток в очереди или null если в очереди нет потоков

public final boolean isQueued(Thread thread)

Parameters:

thread - поток

Returns:

true если указанный поток находится в очереди

Throws:

NullPointerException - если поток равен null

public final boolean hasQueuedPredecessors()

 
 getFirstQueuedThread() != Thread.currentThread()
   && hasQueuedThreads()

 
 protected boolean tryAcquire(long arg) {
   if (isHeldExclusively()) {
     // A reentrant acquire; increment hold count
     return true;
   } else if (hasQueuedPredecessors()) {
     return false;
   } else {
     // try to acquire normally
   }
 }

Returns:

true если в очереди есть поток, предшествующий текущему потоку, и false если текущий поток находится в начале очереди или очередь пуста

Since:

1.7

public final int getQueueLength()

Returns:

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

public final Collection<Thread> getQueuedThreads()

Returns:

коллекция потоков

public final Collection<Thread> getExclusiveQueuedThreads()

Returns:

коллекция потоков

public final Collection<Thread> getSharedQueuedThreads()

Возвращает:

коллекцию потоков

public String toString()

Переопределяет:

toString в классе Object

Возвращает:

строку, идентифицирующую этот синхронизатор, а также его состояние

public final boolean owns(AbstractQueuedLongSynchronizer.ConditionObject condition)

Параметры:

condition - условие

Возвращает:

true, если принадлежит

Исключения:

NullPointerException - если условие равно null

public final boolean hasWaiters(AbstractQueuedLongSynchronizer.ConditionObject condition)

Параметры:

condition - условие

Возвращает:

true, если есть ожидающие потоки

Исключения:

IllegalMonitorStateException - если эксклюзивная синхронизация не удерживается

IllegalArgumentException - если данное условие не связано с этим синхронизатором

NullPointerException - если условие равно null

public final int getWaitQueueLength(AbstractQueuedLongSynchronizer.ConditionObject condition)

Параметры:

condition - условие

Возвращает:

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

Исключения:

IllegalMonitorStateException - если эксклюзивная синхронизация не удерживается

IllegalArgumentException - если данное условие не связано с этим синхронизатором

NullPointerException - если условие равно null

public final Collection<Thread> getWaitingThreads(AbstractQueuedLongSynchronizer.ConditionObject condition)

Параметры:

condition - условие

Возвращает:

коллекцию потоков

Исключения:

IllegalMonitorStateException - если эксклюзивная синхронизация не удерживается

IllegalArgumentException - если данное условие не связано с этим синхронизатором

NullPointerException - если условие равно null