Package org.apache.cassandra.utils.concurrent

Class Awaitable.AsyncAwaitable

java.lang.Object

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

org.apache.cassandra.utils.concurrent.Awaitable.AsyncAwaitable

All Implemented Interfaces:

Awaitable

Direct Known Subclasses:

Condition.Async, CountDownLatch.Async

Enclosing interface:

Awaitable

public abstract static class Awaitable.AsyncAwaitable
extends Awaitable.AbstractAwaitable

A barebones asynchronous Awaitable. If your state is minimal, or can be updated concurrently, 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	AsyncAwaitable()

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.
protected void	signal()	Signal any waiting threads; isSignalled() must return true before this method is invoked.

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

AsyncAwaitable

protected AsyncAwaitable()

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

signal

protected void signal()

Signal any waiting threads; isSignalled() must return true before this method is invoked.

isSignalled

protected abstract boolean isSignalled()

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