Package org.apache.cassandra.utils.concurrent

Interface Condition

All Superinterfaces:

Awaitable

All Known Subinterfaces:

ConditionAsConsumer<T>, WaitQueue.Signal

All Known Implementing Classes:

Condition.Async, Condition.Sync, ConditionAsConsumer.Async, WaitQueue.Standard.AbstractSignal

public interface Condition
extends Awaitable

Simpler API than java.util.concurrent.Condition; would be nice to extend it, but also nice to share API with Future, for which Netty's API is incompatible with java.util.concurrent.Condition Awaitable for explicit external signals.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	Condition.Async	An asynchronous Condition.
static class	Condition.Sync	A Condition based on its object monitor.

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

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

Method Summary

Modifier and Type	Method	Description
boolean	isSignalled()	Returns true once signalled.
static Condition	newOneTimeCondition()	Factory method used to capture and redirect instantiations for simulation
void	signal()	Signal the condition as met, and wake all waiting threads.
default void	signalAll()	Signal the condition as met, and wake all waiting threads.

Methods inherited from interface org.apache.cassandra.utils.concurrent.Awaitable

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

Method Details

isSignalled

boolean isSignalled()

Returns true once signalled. Unidirectional; once true, will never again be false.

signal

void signal()

Signal the condition as met, and wake all waiting threads.

signalAll

default void signalAll()

Signal the condition as met, and wake all waiting threads.

newOneTimeCondition

static Condition newOneTimeCondition()

Factory method used to capture and redirect instantiations for simulation