Package org.apache.cassandra.utils.concurrent

Class Awaitable.SyncAwaitable

java.lang.Object

org.apache.cassandra.utils.concurrent.Awaitable.AbstractAwaitable

org.apache.cassandra.utils.concurrent.Awaitable.SyncAwaitable

All Implemented Interfaces:

Awaitable

Direct Known Subclasses:

Condition.Sync, CountDownLatch.Sync

Enclosing interface:

Awaitable

public abstract static class Awaitable.SyncAwaitable
extends Awaitable.AbstractAwaitable

A barebones Awaitable that uses mutual exclusion. If your state will be updated while holding the object monitor, extend this class.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.cassandra.utils.concurrent.Awaitable

Awaitable.AbstractAwaitable, Awaitable.AsyncAwaitable, Awaitable.Defaults, Awaitable.SyncAwaitable

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SyncAwaitable()

Method Summary

Modifier and Type	Method	Description
Awaitable	await()	Awaitable.await()
boolean	awaitUntil(long nanoTimeDeadline)	Awaitable.awaitUntil(long)
protected abstract boolean	isSignalled()	Return true once signalled.
static boolean	waitUntil(Object monitor, long deadlineNanos)

Methods inherited from class org.apache.cassandra.utils.concurrent.Awaitable.AbstractAwaitable

await, awaitThrowUncheckedOnInterrupt, awaitThrowUncheckedOnInterrupt, awaitUninterruptibly, awaitUninterruptibly, awaitUntilThrowUncheckedOnInterrupt, awaitUntilUninterruptibly

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SyncAwaitable

protected SyncAwaitable()

Method Details

await

public Awaitable await()
                throws InterruptedException

Awaitable.await()

Throws:

InterruptedException - if interrupted

awaitUntil

public boolean awaitUntil(long nanoTimeDeadline)
                   throws InterruptedException

Awaitable.awaitUntil(long)

Returns:

true if we were signalled, false if the deadline elapsed

Throws:

InterruptedException - if interrupted

isSignalled

protected abstract boolean isSignalled()

Return true once signalled. Unidirectional; once true, must never again be false.

waitUntil

public static boolean waitUntil(Object monitor,
 long deadlineNanos)
                         throws InterruptedException

Throws:

InterruptedException