Package org.apache.cassandra.utils.concurrent

Class Awaitable.AbstractAwaitable

java.lang.Object

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

All Implemented Interfaces:

Awaitable

Direct Known Subclasses:

Awaitable.AsyncAwaitable, Awaitable.SyncAwaitable, WaitQueue.Standard.AbstractSignal

Enclosing interface:

Awaitable

public abstract static class Awaitable.AbstractAwaitable
extends Object
implements Awaitable

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	AbstractAwaitable()

Method Summary

Modifier and Type	Method	Description
boolean	await(long time, TimeUnit unit)	Awaitable.await(long, TimeUnit)
Awaitable	awaitThrowUncheckedOnInterrupt()	Awaitable.awaitThrowUncheckedOnInterrupt()
boolean	awaitThrowUncheckedOnInterrupt(long time, TimeUnit units)	Awaitable.awaitThrowUncheckedOnInterrupt(long, TimeUnit)
Awaitable	awaitUninterruptibly()	Awaitable.awaitUninterruptibly()
boolean	awaitUninterruptibly(long time, TimeUnit units)	Awaitable.awaitUninterruptibly(long, TimeUnit)
boolean	awaitUntilThrowUncheckedOnInterrupt(long nanoTimeDeadline)	Awaitable.awaitUntilThrowUncheckedOnInterrupt(long)
boolean	awaitUntilUninterruptibly(long nanoTimeDeadline)	Awaitable.awaitUntilUninterruptibly(long)

Methods inherited from class java.lang.Object

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

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

await, awaitUntil

Constructor Details

AbstractAwaitable

protected AbstractAwaitable()

Method Details

await

public boolean await(long time,
 TimeUnit unit)
              throws InterruptedException

Awaitable.await(long, TimeUnit)

Specified by:

await in interface Awaitable

Returns:

true if we were signalled, false if the timeout elapses

Throws:

InterruptedException - if interrupted

awaitThrowUncheckedOnInterrupt

public boolean awaitThrowUncheckedOnInterrupt(long time,
 TimeUnit units)
                                       throws UncheckedInterruptedException

Awaitable.awaitThrowUncheckedOnInterrupt(long, TimeUnit)

Specified by:

awaitThrowUncheckedOnInterrupt in interface Awaitable

Returns:

true if we were signalled, false if the timeout elapses

Throws:

UncheckedInterruptedException - if interrupted

awaitUninterruptibly

public boolean awaitUninterruptibly(long time,
 TimeUnit units)

Awaitable.awaitUninterruptibly(long, TimeUnit)

Specified by:

awaitUninterruptibly in interface Awaitable

Returns:

true if we were signalled, false if the timeout elapses

awaitThrowUncheckedOnInterrupt

public Awaitable awaitThrowUncheckedOnInterrupt()
                                         throws UncheckedInterruptedException

Awaitable.awaitThrowUncheckedOnInterrupt()

Specified by:

awaitThrowUncheckedOnInterrupt in interface Awaitable

Throws:

UncheckedInterruptedException - if interrupted

awaitUntilThrowUncheckedOnInterrupt

public boolean awaitUntilThrowUncheckedOnInterrupt(long nanoTimeDeadline)
                                            throws UncheckedInterruptedException

Awaitable.awaitUntilThrowUncheckedOnInterrupt(long)

Specified by:

awaitUntilThrowUncheckedOnInterrupt in interface Awaitable

Returns:

true if we were signalled, false if the deadline elapsed

Throws:

UncheckedInterruptedException - if interrupted

awaitUntilUninterruptibly

public boolean awaitUntilUninterruptibly(long nanoTimeDeadline)

Awaitable.awaitUntilUninterruptibly(long)

Specified by:

awaitUntilUninterruptibly in interface Awaitable

Returns:

true if we were signalled, false if the deadline elapsed

awaitUninterruptibly

public Awaitable awaitUninterruptibly()

Awaitable.awaitUninterruptibly()

Specified by:

awaitUninterruptibly in interface Awaitable