Класс 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 — аргумент захвата. Это значение всегда совпадает со значением, переданным методу захвата, либо является значением, сохранённым при входе в ожидание условия. В остальных случаях оно не интерпретируется и может представлять любые данные.

Возвращает:

true при успешном выполнении. В случае успеха этот объект захвачен.

Выбрасывает:

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

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

protected boolean tryRelease(long arg)

Параметры:

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

Возвращает:

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

Выбрасывает:

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

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

protected long tryAcquireShared(long arg)

Параметры:

arg — аргумент захвата. Это значение всегда совпадает со значением, переданным методу захвата, либо является значением, сохранённым при входе в ожидание условия. В остальных случаях оно не интерпретируется и может представлять любые данные.

Возвращает:

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

Выбрасывает:

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

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

protected boolean tryReleaseShared(long arg)

Параметры:

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

Возвращает:

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

Параметры:

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

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

Возвращает:

true, если захват выполнен; false, если истекло время ожидания

Выбрасывает:

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

public final boolean release(long arg)

Параметры:

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

Возвращает:

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

public final void acquireShared(long arg)

Параметры:

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

public final void acquireSharedInterruptibly(long arg) throws InterruptedException

Параметры:

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

Выбрасывает:

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

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

Параметры:

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

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

Возвращает:

true, если захват выполнен; false, если истекло время ожидания

Выбрасывает:

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

public final boolean releaseShared(long arg)

Параметры:

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

Возвращает:

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

public final boolean hasQueuedThreads()

Возвращает:

true, если другие потоки могут ожидать захвата

public final boolean hasContended()

Возвращает:

true, если конкуренция за ресурс когда-либо возникала

public final Thread getFirstQueuedThread()

Возвращает:

первый поток в очереди (ожидающий дольше всех) или null, если в очереди сейчас нет потоков

public final boolean isQueued(Thread thread)

Параметры:

thread — поток

Возвращает:

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

Выбрасывает:

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
  }
}

Возвращает:

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

С:

1.7

public final int getQueueLength()

Возвращает:

оценочное число потоков, ожидающих захвата

public final Collection<Thread> getQueuedThreads()

Возвращает:

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

public final Collection<Thread> getExclusiveQueuedThreads()

Возвращает:

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

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