Package org.apache.cassandra.utils.concurrent

Interface Promise<V>

All Superinterfaces:
Awaitable, io.netty.util.concurrent.Future<V>, Future<V>, Future<V>, com.google.common.util.concurrent.ListenableFuture<V>, io.netty.util.concurrent.Promise<V>
All Known Implementing Classes:
AsyncChannelPromise, AsyncOneResponse, AsyncPromise, AsyncPromise.WithExecutor, SyncPromise, SyncPromise.WithExecutor
public interface Promise<V> extends io.netty.util.concurrent.Promise<V>, Future<V>
A Promise that integrates Promise with our Future API to improve clarity and coherence in the codebase.

  • Method Details

    • listener

      static <V> io.netty.util.concurrent.GenericFutureListener<? extends Future<V>> listener(com.google.common.util.concurrent.FutureCallback<V> callback)

    • listener

      static <V> io.netty.util.concurrent.GenericFutureListener<? extends Future<V>> listener(ExecutorService executor, com.google.common.util.concurrent.FutureCallback<V> callback)

    • addCallback

      Promise<V> addCallback(com.google.common.util.concurrent.FutureCallback<? super V> callback)
      Description copied from interface: Future
      Support Futures.addCallback(com.google.common.util.concurrent.ListenableFuture<V>, com.google.common.util.concurrent.FutureCallback<? super V>, java.util.concurrent.Executor) natively
      Specified by:
      addCallback in interface Future<V>

    • addCallback

      Promise<V> addCallback(com.google.common.util.concurrent.FutureCallback<? super V> callback, Executor executor)
      Description copied from interface: Future
      Support Futures.addCallback(com.google.common.util.concurrent.ListenableFuture<V>, com.google.common.util.concurrent.FutureCallback<? super V>, java.util.concurrent.Executor) natively
      Specified by:
      addCallback in interface Future<V>

    • addCallback

      Promise<V> addCallback(Consumer<? super V> onSuccess, Consumer<? super Throwable> onFailure)
      Description copied from interface: Future
      Support Futures.addCallback(com.google.common.util.concurrent.ListenableFuture<V>, com.google.common.util.concurrent.FutureCallback<? super V>, java.util.concurrent.Executor) natively
      Specified by:
      addCallback in interface Future<V>

    • addListener

      Promise<V> addListener(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>> var1)
      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>

    • addListeners

      Promise<V> addListeners(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>>... var1)
      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>

    • removeListener

      Promise<V> removeListener(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>> var1)
      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>

    • removeListeners

      Promise<V> removeListeners(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>>... var1)
      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>

    • setSuccess

      Promise<V> setSuccess(V v) throws IllegalStateException
      Complete the promise successfully if not already complete
      Specified by:
      setSuccess in interface io.netty.util.concurrent.Promise<V>
      Throws:
      IllegalStateException - if already set

    • setFailure

      Promise<V> setFailure(Throwable throwable) throws IllegalStateException
      Complete the promise abnormally if not already complete
      Specified by:
      setFailure in interface io.netty.util.concurrent.Promise<V>
      Throws:
      IllegalStateException - if already set

    • setUncancellableExclusive

      boolean setUncancellableExclusive()
      Prevent a future caller from cancelling this promise
      Returns:
      true iff this invocation set it to uncancellable, whether or not now uncancellable

    • await

      Promise<V> await() throws InterruptedException
      Wait indefinitely for this promise to complete, throwing any interrupt
      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>
      Throws:
      InterruptedException - if interrupted

    • awaitUninterruptibly

      Promise<V> awaitUninterruptibly()
      Wait indefinitely 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>

    • awaitThrowUncheckedOnInterrupt

      Promise<V> awaitThrowUncheckedOnInterrupt()
      Wait indefinitely for this promise to complete, throwing any interrupt as an UncheckedInterruptedException
      Specified by:
      awaitThrowUncheckedOnInterrupt in interface Awaitable
      Specified by:
      awaitThrowUncheckedOnInterrupt in interface Future<V>
      Throws:
      UncheckedInterruptedException - if interrupted

    • sync

      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>
      Throws:
      InterruptedException

    • syncUninterruptibly

      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>