Класс 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