Package org.apache.cassandra.utils.concurrent

Class AsyncPromise.WithExecutor<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>

org.apache.cassandra.utils.concurrent.AsyncPromise.WithExecutor<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:

AsyncChannelPromise

Enclosing class:

AsyncPromise<V>

public static class AsyncPromise.WithExecutor<V>
extends AsyncPromise<V>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.cassandra.utils.concurrent.AsyncPromise

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

Modifier	Constructor	Description
protected	WithExecutor(Executor notifyExecutor)
protected	WithExecutor(Executor notifyExecutor, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>> listener)
protected	WithExecutor(Executor notifyExecutor, org.apache.cassandra.utils.concurrent.AbstractFuture.FailureHolder initialState)

Method Summary

Modifier and Type	Method	Description
Executor	notifyExecutor()

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

addCallback, addCallback, addCallback, addListener, addListeners, await, awaitThrowUncheckedOnInterrupt, awaitUninterruptibly, isUncancellable, removeListener, removeListeners, setFailure, setSuccess, setUncancellable, setUncancellableExclusive, sync, syncUninterruptibly, tryFailure, trySuccess, uncancellable, uncancellable, uncancellable, withExecutor

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, 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, rethrowIfFailed, syncThrowUncheckedOnInterrupt

Constructor Details

WithExecutor

protected WithExecutor(Executor notifyExecutor)

WithExecutor

protected WithExecutor(Executor notifyExecutor,
 org.apache.cassandra.utils.concurrent.AbstractFuture.FailureHolder initialState)

WithExecutor

protected WithExecutor(Executor notifyExecutor,
 io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>> listener)

Method Details

notifyExecutor

public Executor notifyExecutor()

Specified by:

notifyExecutor in interface Future<V>

Overrides:

notifyExecutor in class AbstractFuture<V>