java.util.concurrent.locks
Class AbstractQueuedSynchronizer.ConditionObject
java.lang.Object
java.util.concurrent.locks.AbstractQueuedSynchronizer.ConditionObject
- AbstractQueuedSynchronizer
- Condition, Serializable
Condition implementation for a
AbstractQueuedSynchronizer
serving as the basis of a
Lock
implementation.
Method documentation for this class describes mechanics,
not behavioral specifications from the point of view of Lock
and Condition users. Exported versions of this class will in
general need to be accompanied by documentation describing
condition semantics that rely on those of the associated
AbstractQueuedSynchronizer.
This class is Serializable, but all fields are transient,
so deserialized conditions have no waiters.
void | await() - Implements interruptible condition wait.
|
boolean | await(long time, TimeUnit unit) - Implements timed condition wait.
|
long | awaitNanos(long nanosTimeout) - Implements timed condition wait.
|
void | awaitUninterruptibly() - Implements uninterruptible condition wait.
|
boolean | awaitUntil(Date deadline) - Implements absolute timed condition wait.
|
protected int | getWaitQueueLength() - Returns an estimate of the number of threads waiting on
this condition.
|
protected Collection | getWaitingThreads() - Returns a collection containing those threads that may be
waiting on this Condition.
|
protected boolean | hasWaiters() - Queries whether any threads are waiting on this condition.
|
void | signal() - Moves the longest-waiting thread, if one exists, from the
wait queue for this condition to the wait queue for the
owning lock.
|
void | signalAll() - Moves all threads from the wait queue for this condition to
the wait queue for the owning lock.
|
clone , equals , extends Object> getClass , finalize , hashCode , notify , notifyAll , toString , wait , wait , wait |
ConditionObject
public ConditionObject()
Creates a new ConditionObject instance.
await
public final void await()
throws InterruptedException
Implements interruptible condition wait.
- If current thread is interrupted, throw InterruptedException
- Save lock state returned by
AbstractQueuedSynchronizer.ConditionObject
- Invoke
AbstractQueuedSynchronizer.ConditionObject
with
saved state as argument, throwing
IllegalMonitorStateException if it fails.
- Block until signalled or interrupted
- Reacquire by invoking specialized version of
AbstractQueuedSynchronizer.ConditionObject
with saved state as argument.
- If interrupted while blocked in step 4, throw exception
- await in interface Condition
await
public final boolean await(long time,
TimeUnit unit)
throws InterruptedException
Implements timed condition wait.
- If current thread is interrupted, throw InterruptedException
- Save lock state returned by
AbstractQueuedSynchronizer.ConditionObject
- Invoke
AbstractQueuedSynchronizer.ConditionObject
with
saved state as argument, throwing
IllegalMonitorStateException if it fails.
- Block until signalled, interrupted, or timed out
- Reacquire by invoking specialized version of
AbstractQueuedSynchronizer.ConditionObject
with saved state as argument.
- If interrupted while blocked in step 4, throw InterruptedException
- If timed out while blocked in step 4, return false, else true
- await in interface Condition
awaitNanos
public final long awaitNanos(long nanosTimeout)
throws InterruptedException
Implements timed condition wait.
- If current thread is interrupted, throw InterruptedException
- Save lock state returned by
AbstractQueuedSynchronizer.ConditionObject
- Invoke
AbstractQueuedSynchronizer.ConditionObject
with
saved state as argument, throwing
IllegalMonitorStateException if it fails.
- Block until signalled, interrupted, or timed out
- Reacquire by invoking specialized version of
AbstractQueuedSynchronizer.ConditionObject
with saved state as argument.
- If interrupted while blocked in step 4, throw InterruptedException
- awaitNanos in interface Condition
awaitUninterruptibly
public final void awaitUninterruptibly()
Implements uninterruptible condition wait.
- Save lock state returned by
AbstractQueuedSynchronizer.ConditionObject
- Invoke
AbstractQueuedSynchronizer.ConditionObject
with
saved state as argument, throwing
IllegalMonitorStateException if it fails.
- Block until signalled
- Reacquire by invoking specialized version of
AbstractQueuedSynchronizer.ConditionObject
with saved state as argument.
- awaitUninterruptibly in interface Condition
awaitUntil
public final boolean awaitUntil(Date deadline)
throws InterruptedException
Implements absolute timed condition wait.
- If current thread is interrupted, throw InterruptedException
- Save lock state returned by
AbstractQueuedSynchronizer.ConditionObject
- Invoke
AbstractQueuedSynchronizer.ConditionObject
with
saved state as argument, throwing
IllegalMonitorStateException if it fails.
- Block until signalled, interrupted, or timed out
- Reacquire by invoking specialized version of
AbstractQueuedSynchronizer.ConditionObject
with saved state as argument.
- If interrupted while blocked in step 4, throw InterruptedException
- If timed out while blocked in step 4, return false, else true
- awaitUntil in interface Condition
getWaitQueueLength
protected final int getWaitQueueLength()
- the estimated number of waiting threads
getWaitingThreads
protected final Collection getWaitingThreads()
- the collection of threads
hasWaiters
protected final boolean hasWaiters()
true
if there are any waiting threads
signal
public final void signal()
Moves the longest-waiting thread, if one exists, from the
wait queue for this condition to the wait queue for the
owning lock.
- signal in interface Condition
signalAll
public final void signalAll()
Moves all threads from the wait queue for this condition to
the wait queue for the owning lock.
- signalAll in interface Condition