Uses of Class
com.google.common.util.concurrent.AbstractFuture
Packages that use AbstractFuture
Package
Description
Concurrency utilities.
-
Uses of AbstractFuture in com.google.common.util.concurrent
Subclasses of AbstractFuture in com.google.common.util.concurrentModifier and TypeClassDescription(package private) classAbstractCatchingFuture<V,X extends Throwable, F, T> Implementations ofFutures.catching*.private static final classAbstractCatchingFuture.AsyncCatchingFuture<V,X extends Throwable> private static final classAbstractCatchingFuture.CatchingFuture<V,X extends Throwable> (package private) static classA less abstract subclass of AbstractFuture.(package private) classAbstractTransformFuture<I,O, F, T> Implementations ofFutures.transform*.private static final classprivate static final class(package private) classAggregateFuture<InputT,OutputT> A future whose value is derived from a collection of input futures.(package private) classAggregateFutureState<OutputT>A helper which does some thread-safe operations for aggregate futures, which must be implemented differently in GWT.(package private) classCollectionFuture<V,C> Aggregate future that collects (stores) results of each future.(package private) static final class(package private) final classAggregate future that computes its value by calling a callable.classFluentFuture<V>AListenableFuturethat supports fluent chains of operations.(package private) static classA less abstract subclass of AbstractFuture.(package private) final classFluentFuturethat forwards all calls to a delegate.private static final classprivate static final classA wrapped future that does not propagate cancellation to its delegate.(package private) classHidden superclass ofFluentFuturethat provides us a place to declare special GWT versions of theFluentFuture.catchingfamily of methods.(package private) static final class(package private) static final classprivate static final classfinal classAListenableFuturewhose result can be set by aSettableFuture.set(Object),SettableFuture.setException(Throwable)orSettableFuture.setFuture(ListenableFuture)call.(package private) final classImplementation ofFutures#withTimeout.(package private) classARunnableFuturethat also implements theListenableFutureinterface.Fields in com.google.common.util.concurrent declared as AbstractFutureModifier and TypeFieldDescription(package private) final AbstractFuture<V>AbstractFuture.SetFuture.ownerFields in com.google.common.util.concurrent with type parameters of type AbstractFutureModifier and TypeFieldDescription(package private) final AtomicReferenceFieldUpdater<AbstractFuture,AbstractFuture.Listener> AbstractFuture.SafeAtomicHelper.listenersUpdater(package private) final AtomicReferenceFieldUpdater<AbstractFuture,Object> AbstractFuture.SafeAtomicHelper.valueUpdater(package private) final AtomicReferenceFieldUpdater<AbstractFuture,AbstractFuture.Waiter> AbstractFuture.SafeAtomicHelper.waitersUpdaterMethods in com.google.common.util.concurrent with parameters of type AbstractFutureModifier and TypeMethodDescription(package private) abstract booleanAbstractFuture.AtomicHelper.casListeners(AbstractFuture<?> future, AbstractFuture.Listener expect, AbstractFuture.Listener update) Performs a CAS operation on thelistenersfield.(package private) booleanAbstractFuture.SafeAtomicHelper.casListeners(AbstractFuture<?> future, AbstractFuture.Listener expect, AbstractFuture.Listener update) (package private) booleanAbstractFuture.SynchronizedHelper.casListeners(AbstractFuture<?> future, AbstractFuture.Listener expect, AbstractFuture.Listener update) (package private) booleanAbstractFuture.UnsafeAtomicHelper.casListeners(AbstractFuture<?> future, AbstractFuture.Listener expect, AbstractFuture.Listener update) Performs a CAS operation on thelistenersfield.(package private) abstract booleanAbstractFuture.AtomicHelper.casValue(AbstractFuture<?> future, Object expect, Object update) Performs a CAS operation on thevaluefield.(package private) booleanAbstractFuture.SafeAtomicHelper.casValue(AbstractFuture<?> future, Object expect, Object update) (package private) booleanAbstractFuture.SynchronizedHelper.casValue(AbstractFuture<?> future, Object expect, Object update) (package private) booleanAbstractFuture.UnsafeAtomicHelper.casValue(AbstractFuture<?> future, Object expect, Object update) Performs a CAS operation on thevaluefield.(package private) abstract booleanAbstractFuture.AtomicHelper.casWaiters(AbstractFuture<?> future, AbstractFuture.Waiter expect, AbstractFuture.Waiter update) Performs a CAS operation on thewaitersfield.(package private) booleanAbstractFuture.SafeAtomicHelper.casWaiters(AbstractFuture<?> future, AbstractFuture.Waiter expect, AbstractFuture.Waiter update) (package private) booleanAbstractFuture.SynchronizedHelper.casWaiters(AbstractFuture<?> future, AbstractFuture.Waiter expect, AbstractFuture.Waiter update) (package private) booleanAbstractFuture.UnsafeAtomicHelper.casWaiters(AbstractFuture<?> future, AbstractFuture.Waiter expect, AbstractFuture.Waiter update) Performs a CAS operation on thewaitersfield.private static voidAbstractFuture.complete(AbstractFuture<?> param, boolean callInterruptTask) Unblocks all threads and runs all listeners.(package private) abstract AbstractFuture.ListenerAbstractFuture.AtomicHelper.gasListeners(AbstractFuture<?> future, AbstractFuture.Listener update) Performs a GAS operation on thelistenersfield.(package private) AbstractFuture.ListenerAbstractFuture.SafeAtomicHelper.gasListeners(AbstractFuture<?> future, AbstractFuture.Listener update) Performs a GAS operation on thelistenersfield.(package private) AbstractFuture.ListenerAbstractFuture.SynchronizedHelper.gasListeners(AbstractFuture<?> future, AbstractFuture.Listener update) Performs a GAS operation on thelistenersfield.(package private) AbstractFuture.ListenerAbstractFuture.UnsafeAtomicHelper.gasListeners(AbstractFuture<?> future, AbstractFuture.Listener update) Performs a GAS operation on thelistenersfield.(package private) abstract AbstractFuture.WaiterAbstractFuture.AtomicHelper.gasWaiters(AbstractFuture<?> future, AbstractFuture.Waiter update) Performs a GAS operation on thewaitersfield.(package private) AbstractFuture.WaiterAbstractFuture.SafeAtomicHelper.gasWaiters(AbstractFuture<?> future, AbstractFuture.Waiter update) Performs a GAS operation on thewaitersfield.(package private) AbstractFuture.WaiterAbstractFuture.SynchronizedHelper.gasWaiters(AbstractFuture<?> future, AbstractFuture.Waiter update) Performs a GAS operation on thewaitersfield.(package private) AbstractFuture.WaiterAbstractFuture.UnsafeAtomicHelper.gasWaiters(AbstractFuture<?> future, AbstractFuture.Waiter update) Performs a GAS operation on thewaitersfield.(package private) static ExecutorMoreExecutors.rejectionPropagatingExecutor(Executor delegate, AbstractFuture<?> future) Returns an Executor that will propagateRejectedExecutionExceptionfrom the delegate executor to the givenfuture.Method parameters in com.google.common.util.concurrent with type arguments of type AbstractFutureModifier and TypeMethodDescriptionprivate voidFutures.InCompletionOrderState.recordInputCompletion(ImmutableList<AbstractFuture<T>> delegates, int inputFutureIndex) Constructors in com.google.common.util.concurrent with parameters of type AbstractFutureModifierConstructorDescription(package private)SetFuture(AbstractFuture<V> owner, ListenableFuture<? extends V> future) -
Uses of AbstractFuture in com.google.common.util.concurrent.testing
Subclasses of AbstractFuture in com.google.common.util.concurrent.testingModifier and TypeClassDescriptionprivate static class