Package org.apache.cassandra.utils.concurrent

Class AsyncPromise<V>

java.lang.Object

org.apache.cassandra.utils.concurrent.AbstractFuture<V>

org.apache.cassandra.utils.concurrent.AsyncFuture<V>

org.apache.cassandra.utils.concurrent.AsyncPromise<V>

All Implemented Interfaces:

com.google.common.util.concurrent.ListenableFuture<V>, io.netty.util.concurrent.Future<V>, io.netty.util.concurrent.Promise<V>, Future<V>, Awaitable, Future<V>, Promise<V>

Direct Known Subclasses:

AsyncOneResponse, AsyncPromise.WithExecutor

public class AsyncPromise<V>
extends AsyncFuture<V>
implements Promise<V>

Extends AsyncFuture to implement the Promise interface.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AsyncPromise.WithExecutor<V>

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

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

Field Summary

Fields inherited from class org.apache.cassandra.utils.concurrent.AbstractFuture

CANCELLED, UNCANCELLABLE, UNSET

Constructor Summary

Constructors

Constructor	Description
AsyncPromise()
AsyncPromise(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>> listener)

Method Summary

Modifier and Type	Method	Description
AsyncPromise<V>	addCallback(com.google.common.util.concurrent.FutureCallback<? super V> callback)	Support Futures.addCallback(com.google.common.util.concurrent.ListenableFuture<V>, com.google.common.util.concurrent.FutureCallback<? super V>, java.util.concurrent.Executor) natively See AbstractFuture.addListener(GenericFutureListener) for ordering semantics.
AsyncPromise<V>	addCallback(com.google.common.util.concurrent.FutureCallback<? super V> callback, Executor executor)	Support Futures.addCallback(com.google.common.util.concurrent.ListenableFuture<V>, com.google.common.util.concurrent.FutureCallback<? super V>, java.util.concurrent.Executor) natively See AbstractFuture.addListener(GenericFutureListener) for ordering semantics.
AsyncPromise<V>	addCallback(Consumer<? super V> onSuccess, Consumer<? super Throwable> onFailure)	Support more fluid version of Futures.addCallback(com.google.common.util.concurrent.ListenableFuture<V>, com.google.common.util.concurrent.FutureCallback<? super V>, java.util.concurrent.Executor) See AbstractFuture.addListener(GenericFutureListener) for ordering semantics.
AsyncPromise<V>	addListener(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>> listener)	Add a listener to be invoked once this future completes.
AsyncPromise<V>	addListeners(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>>... listeners)
AsyncPromise<V>	await()	Wait for this promise to complete
AsyncPromise<V>	awaitThrowUncheckedOnInterrupt()	Wait for this promise to complete, throwing any interrupt as an UncheckedInterruptedException
AsyncPromise<V>	awaitUninterruptibly()	Wait uninterruptibly for this promise to complete
boolean	isUncancellable()
AsyncPromise<V>	removeListener(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>> listener)
AsyncPromise<V>	removeListeners(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>>... listeners)
Promise<V>	setFailure(Throwable throwable)	Complete the promise abnormally if not already complete
Promise<V>	setSuccess(V v)	Complete the promise successfully if not already complete
boolean	setUncancellable()	Prevent a future caller from cancelling this promise
boolean	setUncancellableExclusive()	Prevent a future caller from cancelling this promise
Promise<V>	sync()	waits for completion; in case of failure rethrows the original exception without a new wrapping exception so may cause problems for reporting stack traces
Promise<V>	syncUninterruptibly()	waits for completion; in case of failure rethrows the original exception without a new wrapping exception so may cause problems for reporting stack traces
boolean	tryFailure(Throwable throwable)	Complete the promise abnormally if not already complete
boolean	trySuccess(V v)	Complete the promise successfully if not already complete
static <V> AsyncPromise<V>	uncancellable()
static <V> AsyncPromise<V>	uncancellable(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>> listener)
static <V> AsyncPromise<V>	uncancellable(Executor executor)
static <V> AsyncPromise<V>	withExecutor(Executor executor)

Methods inherited from class org.apache.cassandra.utils.concurrent.AsyncFuture

awaitUntil, flatMap, map

Methods inherited from class org.apache.cassandra.utils.concurrent.AbstractFuture

addCallback, addCallback, addCallback, addListener, addListener, await, awaitThrowUncheckedOnInterrupt, awaitUninterruptibly, awaitUntilThrowUncheckedOnInterrupt, awaitUntilUninterruptibly, cancel, cause, description, flatMap, get, get, getNow, getWhenDone, isCancellable, isCancelled, isDone, isSuccess, map, map, notifyExecutor, toString

Methods inherited from class java.lang.Object

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

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

await, awaitThrowUncheckedOnInterrupt, awaitUninterruptibly, awaitUntil, awaitUntilThrowUncheckedOnInterrupt, awaitUntilUninterruptibly

Methods inherited from interface io.netty.util.concurrent.Future

await, awaitUninterruptibly, cancel, cause, getNow, isCancellable, isSuccess

Methods inherited from interface java.util.concurrent.Future

get, get, isCancelled, isDone

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

addCallback, addCallback, addCallback, addListener, addListener, await, awaitUninterruptibly, flatMap, flatMap, map, map, notifyExecutor, rethrowIfFailed, syncThrowUncheckedOnInterrupt

Constructor Details

AsyncPromise

public AsyncPromise()

AsyncPromise

public AsyncPromise(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>> listener)

Method Details

withExecutor

public static <V> AsyncPromise<V> withExecutor(Executor executor)

uncancellable

public static <V> AsyncPromise<V> uncancellable()

uncancellable

public static <V> AsyncPromise<V> uncancellable(Executor executor)

uncancellable

public static <V> AsyncPromise<V> uncancellable(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>> listener)

setSuccess

public Promise<V> setSuccess(V v)

Complete the promise successfully if not already complete

Specified by:

setSuccess in interface io.netty.util.concurrent.Promise<V>

Specified by:

setSuccess in interface Promise<V>

Throws:

IllegalStateException - if already set

trySuccess

public boolean trySuccess(V v)

Complete the promise successfully if not already complete

Specified by:

trySuccess in interface io.netty.util.concurrent.Promise<V>

Overrides:

trySuccess in class AbstractFuture<V>

Returns:

true iff completed promise

setFailure

public Promise<V> setFailure(Throwable throwable)

Complete the promise abnormally if not already complete

Specified by:

setFailure in interface io.netty.util.concurrent.Promise<V>

Specified by:

setFailure in interface Promise<V>

Throws:

IllegalStateException - if already set

tryFailure

public boolean tryFailure(Throwable throwable)

Complete the promise abnormally if not already complete

Specified by:

tryFailure in interface io.netty.util.concurrent.Promise<V>

Overrides:

tryFailure in class AbstractFuture<V>

Returns:

true iff completed promise

setUncancellable

public boolean setUncancellable()

Prevent a future caller from cancelling this promise

Specified by:

setUncancellable in interface io.netty.util.concurrent.Promise<V>

Overrides:

setUncancellable in class AbstractFuture<V>

Returns:

true if the promise is now uncancellable (whether or not we did this)

setUncancellableExclusive

public boolean setUncancellableExclusive()

Prevent a future caller from cancelling this promise

Specified by:

setUncancellableExclusive in interface Promise<V>

Overrides:

setUncancellableExclusive in class AbstractFuture<V>

Returns:

true iff this invocation set it to uncancellable, whether or not now uncancellable

isUncancellable

public boolean isUncancellable()

Overrides:

isUncancellable in class AbstractFuture<V>

sync

public Promise<V> sync()
                throws InterruptedException

waits for completion; in case of failure rethrows the original exception without a new wrapping exception so may cause problems for reporting stack traces

Specified by:

sync in interface io.netty.util.concurrent.Future<V>

Specified by:

sync in interface Future<V>

Specified by:

sync in interface io.netty.util.concurrent.Promise<V>

Specified by:

sync in interface Promise<V>

Throws:

InterruptedException

syncUninterruptibly

public Promise<V> syncUninterruptibly()

waits for completion; in case of failure rethrows the original exception without a new wrapping exception so may cause problems for reporting stack traces

Specified by:

syncUninterruptibly in interface io.netty.util.concurrent.Future<V>

Specified by:

syncUninterruptibly in interface Future<V>

Specified by:

syncUninterruptibly in interface io.netty.util.concurrent.Promise<V>

Specified by:

syncUninterruptibly in interface Promise<V>

addListener

public AsyncPromise<V> addListener(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>> listener)

Description copied from class: AbstractFuture

Add a listener to be invoked once this future completes. Listeners are submitted to AbstractFuture.notifyExecutor() in the order they are added (or the specified executor in the case of AbstractFuture.addListener(Runnable, Executor). if AbstractFuture.notifyExecutor() is unset, they are invoked in the order they are added. The ordering holds across all variants of this method.

Specified by:

addListener in interface io.netty.util.concurrent.Future<V>

Specified by:

addListener in interface Future<V>

Specified by:

addListener in interface io.netty.util.concurrent.Promise<V>

Specified by:

addListener in interface Promise<V>

Overrides:

addListener in class AbstractFuture<V>

addListeners

public AsyncPromise<V> addListeners(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>>... listeners)

Specified by:

addListeners in interface io.netty.util.concurrent.Future<V>

Specified by:

addListeners in interface Future<V>

Specified by:

addListeners in interface io.netty.util.concurrent.Promise<V>

Specified by:

addListeners in interface Promise<V>

Overrides:

addListeners in class AbstractFuture<V>

removeListener

public AsyncPromise<V> removeListener(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>> listener)

Specified by:

removeListener in interface io.netty.util.concurrent.Future<V>

Specified by:

removeListener in interface Future<V>

Specified by:

removeListener in interface io.netty.util.concurrent.Promise<V>

Specified by:

removeListener in interface Promise<V>

Overrides:

removeListener in class AbstractFuture<V>

removeListeners

public AsyncPromise<V> removeListeners(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>>... listeners)

Specified by:

removeListeners in interface io.netty.util.concurrent.Future<V>

Specified by:

removeListeners in interface Future<V>

Specified by:

removeListeners in interface io.netty.util.concurrent.Promise<V>

Specified by:

removeListeners in interface Promise<V>

Overrides:

removeListeners in class AbstractFuture<V>

addCallback

public AsyncPromise<V> addCallback(com.google.common.util.concurrent.FutureCallback<? super V> callback)

Description copied from class: AbstractFuture

Support Futures.addCallback(com.google.common.util.concurrent.ListenableFuture<V>, com.google.common.util.concurrent.FutureCallback<? super V>, java.util.concurrent.Executor) natively See AbstractFuture.addListener(GenericFutureListener) for ordering semantics.

Specified by:

addCallback in interface Future<V>

Specified by:

addCallback in interface Promise<V>

Overrides:

addCallback in class AbstractFuture<V>

addCallback

public AsyncPromise<V> addCallback(com.google.common.util.concurrent.FutureCallback<? super V> callback,
 Executor executor)

Description copied from class: AbstractFuture

Support Futures.addCallback(com.google.common.util.concurrent.ListenableFuture<V>, com.google.common.util.concurrent.FutureCallback<? super V>, java.util.concurrent.Executor) natively See AbstractFuture.addListener(GenericFutureListener) for ordering semantics.

Specified by:

addCallback in interface Future<V>

Specified by:

addCallback in interface Promise<V>

Overrides:

addCallback in class AbstractFuture<V>

addCallback

public AsyncPromise<V> addCallback(Consumer<? super V> onSuccess,
 Consumer<? super Throwable> onFailure)

Description copied from class: AbstractFuture

Support more fluid version of Futures.addCallback(com.google.common.util.concurrent.ListenableFuture<V>, com.google.common.util.concurrent.FutureCallback<? super V>, java.util.concurrent.Executor) See AbstractFuture.addListener(GenericFutureListener) for ordering semantics.

Specified by:

addCallback in interface Future<V>

Specified by:

addCallback in interface Promise<V>

Overrides:

addCallback in class AbstractFuture<V>

await

public AsyncPromise<V> await()
                      throws InterruptedException

Wait for this promise to complete

Specified by:

await in interface Awaitable

Specified by:

await in interface io.netty.util.concurrent.Future<V>

Specified by:

await in interface Future<V>

Specified by:

await in interface io.netty.util.concurrent.Promise<V>

Specified by:

await in interface Promise<V>

Overrides:

await in class AsyncFuture<V>

Throws:

InterruptedException - if interrupted

awaitUninterruptibly

public AsyncPromise<V> awaitUninterruptibly()

Wait uninterruptibly for this promise to complete

Specified by:

awaitUninterruptibly in interface Awaitable

Specified by:

awaitUninterruptibly in interface io.netty.util.concurrent.Future<V>

Specified by:

awaitUninterruptibly in interface Future<V>

Specified by:

awaitUninterruptibly in interface io.netty.util.concurrent.Promise<V>

Specified by:

awaitUninterruptibly in interface Promise<V>

Overrides:

awaitUninterruptibly in class AbstractFuture<V>

awaitThrowUncheckedOnInterrupt

public AsyncPromise<V> awaitThrowUncheckedOnInterrupt()
                                               throws UncheckedInterruptedException

Wait for this promise to complete, throwing any interrupt as an UncheckedInterruptedException

Specified by:

awaitThrowUncheckedOnInterrupt in interface Awaitable

Specified by:

awaitThrowUncheckedOnInterrupt in interface Future<V>

Specified by:

awaitThrowUncheckedOnInterrupt in interface Promise<V>

Overrides:

awaitThrowUncheckedOnInterrupt in class AbstractFuture<V>

Throws:

UncheckedInterruptedException - if interrupted