Class CombinedFuture.CombinedFutureInterruptibleTask<T>

java.lang.Object
java.util.concurrent.atomic.AtomicReference<Runnable>
com.google.common.util.concurrent.InterruptibleTask<T>
com.google.common.util.concurrent.CombinedFuture.CombinedFutureInterruptibleTask<T>
All Implemented Interfaces:
Serializable, Runnable
Direct Known Subclasses:
CombinedFuture.AsyncCallableInterruptibleTask, CombinedFuture.CallableInterruptibleTask
Enclosing class:
CombinedFuture<V>

private abstract class CombinedFuture.CombinedFutureInterruptibleTask<T> extends InterruptibleTask<T>
  • Field Details

    • listenerExecutor

      private final Executor listenerExecutor
  • Constructor Details

    • CombinedFutureInterruptibleTask

      CombinedFutureInterruptibleTask(Executor listenerExecutor)
  • Method Details

    • isDone

      final boolean isDone()
      Description copied from class: InterruptibleTask
      Called before runInterruptibly - if true, runInterruptibly and afterRanInterruptibly will not be called.
      Specified by:
      isDone in class InterruptibleTask<T>
    • execute

      final void execute()
    • afterRanInterruptiblySuccess

      final void afterRanInterruptiblySuccess(T result)
      Description copied from class: InterruptibleTask
      Any interruption that happens as a result of calling interruptTask will arrive before this method is called. Complete Futures here.
      Specified by:
      afterRanInterruptiblySuccess in class InterruptibleTask<T>
    • afterRanInterruptiblyFailure

      final void afterRanInterruptiblyFailure(Throwable error)
      Description copied from class: InterruptibleTask
      Any interruption that happens as a result of calling interruptTask will arrive before this method is called. Complete Futures here.
      Specified by:
      afterRanInterruptiblyFailure in class InterruptibleTask<T>
    • setValue

      abstract void setValue(T value)