Uses of Interface
com.google.common.util.concurrent.ListenableFuture
-
Packages that use ListenableFuture Package Description com.google.common.cache This package contains caching utilities.com.google.common.util.concurrent Concurrency utilities.com.google.common.util.concurrent.testing -
-
Uses of ListenableFuture in com.google.common.cache
Methods in com.google.common.cache that return ListenableFuture Modifier and Type Method Description private ListenableFuture<V>
LocalCache.LoadingValueReference. fullyFailedFuture(java.lang.Throwable t)
(package private) ListenableFuture<V>
LocalCache.Segment. loadAsync(K key, int hash, LocalCache.LoadingValueReference<K,V> loadingValueReference, CacheLoader<? super K,V> loader)
ListenableFuture<V>
LocalCache.LoadingValueReference. loadFuture(K key, CacheLoader<? super K,V> loader)
ListenableFuture<V>
CacheLoader. reload(K key, V oldValue)
Computes or retrieves a replacement value corresponding to an already-cachedkey
.Methods in com.google.common.cache with parameters of type ListenableFuture Modifier and Type Method Description (package private) V
LocalCache.Segment. getAndRecordStats(K key, int hash, LocalCache.LoadingValueReference<K,V> loadingValueReference, ListenableFuture<V> newValue)
Waits uninterruptibly fornewValue
to be loaded, and then records loading stats. -
Uses of ListenableFuture in com.google.common.util.concurrent
Subinterfaces of ListenableFuture in com.google.common.util.concurrent Modifier and Type Interface Description (package private) static interface
AbstractFuture.Trusted<V>
Tag interface marking trusted subclasses.interface
ListenableScheduledFuture<V>
Helper interface to implement bothListenableFuture
andScheduledFuture
.Classes in com.google.common.util.concurrent that implement ListenableFuture Modifier and Type Class Description (package private) class
AbstractCatchingFuture<V,X extends java.lang.Throwable,F,T>
Implementations ofFutures.catching*
.private static class
AbstractCatchingFuture.AsyncCatchingFuture<V,X extends java.lang.Throwable>
AnAbstractCatchingFuture
that delegates to anAsyncFunction
andAbstractFuture.setFuture(ListenableFuture)
.private static class
AbstractCatchingFuture.CatchingFuture<V,X extends java.lang.Throwable>
class
AbstractFuture<V>
An abstract implementation ofListenableFuture
, intended for advanced users only.(package private) static class
AbstractFuture.TrustedFuture<V>
A less abstract subclass of AbstractFuture.(package private) class
AbstractTransformFuture<I,O,F,T>
Implementations ofFutures.transform*
.private static class
AbstractTransformFuture.AsyncTransformFuture<I,O>
AnAbstractTransformFuture
that delegates to anAsyncFunction
andAbstractFuture.setFuture(ListenableFuture)
.private static class
AbstractTransformFuture.TransformFuture<I,O>
(package private) class
AggregateFuture<InputT,OutputT>
A future whose value is derived from a collection of input futures.(package private) class
AggregateFutureState<OutputT>
A helper which does some thread-safe operations for aggregate futures, which must be implemented differently in GWT.(package private) class
CollectionFuture<V,C>
Aggregate future that collects (stores) results of each future.(package private) static class
CollectionFuture.ListFuture<V>
(package private) class
CombinedFuture<V>
Aggregate future that computes its value by calling a callable.class
FluentFuture<V>
AListenableFuture
that supports fluent chains of operations.(package private) static class
FluentFuture.TrustedFuture<V>
A less abstract subclass of AbstractFuture.(package private) class
ForwardingFluentFuture<V>
FluentFuture
that forwards all calls to a delegate.class
ForwardingListenableFuture<V>
AListenableFuture
which forwards all its method calls to another future.static class
ForwardingListenableFuture.SimpleForwardingListenableFuture<V>
A simplified version ofForwardingListenableFuture
where subclasses can pass in an already constructedListenableFuture
as the delegate.private static class
Futures.InCompletionOrderFuture<T>
private static class
Futures.NonCancellationPropagatingFuture<V>
A wrapped future that does not propagate cancellation to its delegate.(package private) class
GwtFluentFutureCatchingSpecialization<V>
Hidden superclass ofFluentFuture
that provides us a place to declare special GWT versions of theFluentFuture.catching
family of methods.(package private) class
ImmediateFuture<V>
Implementation ofFutures.immediateFuture(V)
.(package private) static class
ImmediateFuture.ImmediateCancelledFuture<V>
(package private) static class
ImmediateFuture.ImmediateFailedFuture<V>
private static class
JdkFutureAdapters.ListenableFutureAdapter<V>
An adapter to turn aFuture
into aListenableFuture
.class
ListenableFutureTask<V>
AFutureTask
that also implements theListenableFuture
interface.private static class
MoreExecutors.ScheduledListeningDecorator.ListenableScheduledTask<V>
private static class
MoreExecutors.ScheduledListeningDecorator.NeverSuccessfulListenableFutureTask
class
SettableFuture<V>
AListenableFuture
whose result can be set by aSettableFuture.set(Object)
,SettableFuture.setException(Throwable)
orSettableFuture.setFuture(ListenableFuture)
call.(package private) class
TimeoutFuture<V>
Implementation ofFutures#withTimeout
.(package private) class
TrustedListenableFutureTask<V>
ARunnableFuture
that also implements theListenableFuture
interface.Fields in com.google.common.util.concurrent declared as ListenableFuture Modifier and Type Field Description private ListenableFuture<V>
ForwardingFluentFuture. delegate
private ListenableFuture<V>
ForwardingListenableFuture.SimpleForwardingListenableFuture. delegate
private ListenableFuture<V>
Futures.NonCancellationPropagatingFuture. delegate
private ListenableFuture<V>
TimeoutFuture. delegateRef
(package private) ListenableFuture<? extends V>
AbstractFuture.SetFuture. future
(package private) ListenableFuture<? extends V>
AbstractCatchingFuture. inputFuture
(package private) ListenableFuture<? extends I>
AbstractTransformFuture. inputFuture
private ListenableFuture<? extends T>[]
Futures.InCompletionOrderState. inputFutures
(package private) static ListenableFuture<?>
ImmediateFuture. NULL
Fields in com.google.common.util.concurrent with type parameters of type ListenableFuture Modifier and Type Field Description private ImmutableCollection<? extends ListenableFuture<? extends InputT>>
AggregateFuture. futures
The input futures.private ImmutableList<ListenableFuture<? extends V>>
Futures.FutureCombiner. futures
private java.util.concurrent.atomic.AtomicReference<ListenableFuture<java.lang.Void>>
ExecutionSequencer. ref
This reference acts as a pointer tracking the head of a linked list of ListenableFutures.Methods in com.google.common.util.concurrent that return ListenableFuture Modifier and Type Method Description static <V> ListenableFuture<java.util.List<V>>
Futures. allAsList(ListenableFuture<? extends V>... futures)
Creates a newListenableFuture
whose value is a list containing the values of all its input futures, if all succeed.static <V> ListenableFuture<java.util.List<V>>
Futures. allAsList(java.lang.Iterable<? extends ListenableFuture<? extends V>> futures)
Creates a newListenableFuture
whose value is a list containing the values of all its input futures, if all succeed.ListenableFuture<O>
AsyncFunction. apply(I input)
Returns an outputFuture
to use in place of the giveninput
.(package private) <V,U>
ListenableFuture<U>ClosingFuture.CloseableList. applyClosingFunction(ClosingFuture.ClosingFunction<? super V,U> transformation, V input)
ListenableFuture<V>
AsyncCallable. call()
Computes a resultFuture
.<C> ListenableFuture<C>
Futures.FutureCombiner. call(java.util.concurrent.Callable<C> combiner, java.util.concurrent.Executor executor)
Creates theListenableFuture
which will return the result of callingCallable.call()
incombiner
when all futures complete, using the specifiedexecutor
.<C> ListenableFuture<C>
Futures.FutureCombiner. callAsync(AsyncCallable<C> combiner, java.util.concurrent.Executor executor)
Creates theListenableFuture
which will return the result of callingAsyncCallable.call()
incombiner
when all futures complete, using the specifiedexecutor
.static <V,X extends java.lang.Throwable>
ListenableFuture<V>Futures. catching(ListenableFuture<? extends V> input, java.lang.Class<X> exceptionType, Function<? super X,? extends V> fallback, java.util.concurrent.Executor executor)
Returns aFuture
whose result is taken from the given primaryinput
or, if the primary input fails with the givenexceptionType
, from the result provided by thefallback
.static <V,X extends java.lang.Throwable>
ListenableFuture<V>Futures. catchingAsync(ListenableFuture<? extends V> input, java.lang.Class<X> exceptionType, AsyncFunction<? super X,? extends V> fallback, java.util.concurrent.Executor executor)
Returns aFuture
whose result is taken from the given primaryinput
or, if the primary input fails with the givenexceptionType
, from the result provided by thefallback
.(package private) static <V,X extends java.lang.Throwable>
ListenableFuture<V>AbstractCatchingFuture. create(ListenableFuture<? extends V> input, java.lang.Class<X> exceptionType, Function<? super X,? extends V> fallback, java.util.concurrent.Executor executor)
(package private) static <X extends java.lang.Throwable,V>
ListenableFuture<V>AbstractCatchingFuture. create(ListenableFuture<? extends V> input, java.lang.Class<X> exceptionType, AsyncFunction<? super X,? extends V> fallback, java.util.concurrent.Executor executor)
(package private) static <I,O>
ListenableFuture<O>AbstractTransformFuture. create(ListenableFuture<I> input, Function<? super I,? extends O> function, java.util.concurrent.Executor executor)
(package private) static <I,O>
ListenableFuture<O>AbstractTransformFuture. create(ListenableFuture<I> input, AsyncFunction<? super I,? extends O> function, java.util.concurrent.Executor executor)
(package private) static <V> ListenableFuture<V>
TimeoutFuture. create(ListenableFuture<V> delegate, long time, java.util.concurrent.TimeUnit unit, java.util.concurrent.ScheduledExecutorService scheduledExecutor)
protected abstract ListenableFuture<? extends V>
ForwardingListenableFuture. delegate()
protected ListenableFuture<V>
ForwardingListenableFuture.SimpleForwardingListenableFuture. delegate()
(package private) ListenableFuture<? extends V>
AbstractCatchingFuture.AsyncCatchingFuture. doFallback(AsyncFunction<? super X,? extends V> fallback, X cause)
(package private) ListenableFuture<? extends O>
AbstractTransformFuture.AsyncTransformFuture. doTransform(AsyncFunction<? super I,? extends O> function, I input)
static <V> ListenableFuture<V>
Futures. immediateCancelledFuture()
Creates aListenableFuture
which is cancelled immediately upon construction, so thatisCancelled()
always returnstrue
.static <V> ListenableFuture<V>
Futures. immediateFailedFuture(java.lang.Throwable throwable)
Returns aListenableFuture
which has an exception set immediately upon construction.static <V> ListenableFuture<V>
Futures. immediateFuture(V value)
Creates aListenableFuture
which has its value set immediately upon construction.static ListenableFuture<java.lang.Void>
Futures. immediateVoidFuture()
Returns a successfulListenableFuture<Void>
.static <V> ListenableFuture<V>
JdkFutureAdapters. listenInPoolThread(java.util.concurrent.Future<V> future)
Assigns a thread to the givenFuture
to provideListenableFuture
functionality.static <V> ListenableFuture<V>
JdkFutureAdapters. listenInPoolThread(java.util.concurrent.Future<V> future, java.util.concurrent.Executor executor)
Submits a blocking task for the givenFuture
to provideListenableFuture
functionality.static <V> ListenableFuture<V>
Futures. nonCancellationPropagating(ListenableFuture<V> future)
Returns aListenableFuture
whose result is set from the supplied future when it completes.ListenableFuture<?>
Futures.FutureCombiner. run(java.lang.Runnable combiner, java.util.concurrent.Executor executor)
Creates theListenableFuture
which will return the result of runningcombiner
when all Futures complete.(package private) ListenableFuture<V>
CombinedFuture.AsyncCallableInterruptibleTask. runInterruptibly()
(package private) ListenableFuture<V>
TrustedListenableFutureTask.TrustedFutureInterruptibleAsyncTask. runInterruptibly()
static <O> ListenableFuture<O>
Futures. scheduleAsync(AsyncCallable<O> callable, long delay, java.util.concurrent.TimeUnit timeUnit, java.util.concurrent.ScheduledExecutorService executorService)
Schedulescallable
on the specifiedexecutor
, returning aFuture
.static <O> ListenableFuture<O>
Futures. scheduleAsync(AsyncCallable<O> callable, java.time.Duration delay, java.util.concurrent.ScheduledExecutorService executorService)
Schedulescallable
on the specifiedexecutor
, returning aFuture
.ListenableFuture<?>
ClosingFuture. statusFuture()
Returns a future that finishes when this step does.ListenableFuture<?>
AbstractListeningExecutorService. submit(java.lang.Runnable task)
<T> ListenableFuture<T>
AbstractListeningExecutorService. submit(java.lang.Runnable task, T result)
<T> ListenableFuture<T>
AbstractListeningExecutorService. submit(java.util.concurrent.Callable<T> task)
<T> ListenableFuture<T>
ExecutionSequencer. submit(java.util.concurrent.Callable<T> callable, java.util.concurrent.Executor executor)
Enqueues a task to run when the previous task (if any) completes.ListenableFuture<?>
ForwardingListeningExecutorService. submit(java.lang.Runnable task)
<T> ListenableFuture<T>
ForwardingListeningExecutorService. submit(java.lang.Runnable task, T result)
<T> ListenableFuture<T>
ForwardingListeningExecutorService. submit(java.util.concurrent.Callable<T> task)
static ListenableFuture<java.lang.Void>
Futures. submit(java.lang.Runnable runnable, java.util.concurrent.Executor executor)
Executesrunnable
on the specifiedexecutor
, returning aFuture
that will complete after execution.static <O> ListenableFuture<O>
Futures. submit(java.util.concurrent.Callable<O> callable, java.util.concurrent.Executor executor)
Executescallable
on the specifiedexecutor
, returning aFuture
.ListenableFuture<?>
ListeningExecutorService. submit(java.lang.Runnable task)
<T> ListenableFuture<T>
ListeningExecutorService. submit(java.lang.Runnable task, T result)
<T> ListenableFuture<T>
ListeningExecutorService. submit(java.util.concurrent.Callable<T> task)
private static <T> ListenableFuture<T>
MoreExecutors. submitAndAddQueueListener(ListeningExecutorService executorService, java.util.concurrent.Callable<T> task, java.util.concurrent.BlockingQueue<java.util.concurrent.Future<T>> queue)
Submits the task and adds a listener that adds the future toqueue
when it completes.<T> ListenableFuture<T>
ExecutionSequencer. submitAsync(AsyncCallable<T> callable, java.util.concurrent.Executor executor)
Enqueues a task to run when the previous task (if any) completes.static <O> ListenableFuture<O>
Futures. submitAsync(AsyncCallable<O> callable, java.util.concurrent.Executor executor)
Executescallable
on the specifiedexecutor
, returning aFuture
.static <V> ListenableFuture<java.util.List<V>>
Futures. successfulAsList(ListenableFuture<? extends V>... futures)
Creates a newListenableFuture
whose value is a list containing the values of all its successful input futures.static <V> ListenableFuture<java.util.List<V>>
Futures. successfulAsList(java.lang.Iterable<? extends ListenableFuture<? extends V>> futures)
Creates a newListenableFuture
whose value is a list containing the values of all its successful input futures.static <I,O>
ListenableFuture<O>Futures. transform(ListenableFuture<I> input, Function<? super I,? extends O> function, java.util.concurrent.Executor executor)
Returns a newFuture
whose result is derived from the result of the givenFuture
.static <I,O>
ListenableFuture<O>Futures. transformAsync(ListenableFuture<I> input, AsyncFunction<? super I,? extends O> function, java.util.concurrent.Executor executor)
Returns a newFuture
whose result is asynchronously derived from the result of the givenFuture
.static <V> ListenableFuture<V>
Futures. withTimeout(ListenableFuture<V> delegate, long time, java.util.concurrent.TimeUnit unit, java.util.concurrent.ScheduledExecutorService scheduledExecutor)
Returns a future that delegates to another but will finish early (via aTimeoutException
wrapped in anExecutionException
) if the specified duration expires.static <V> ListenableFuture<V>
Futures. withTimeout(ListenableFuture<V> delegate, java.time.Duration time, java.util.concurrent.ScheduledExecutorService scheduledExecutor)
Returns a future that delegates to another but will finish early (via aTimeoutException
wrapped in anExecutionException
) if the specified duration expires.Methods in com.google.common.util.concurrent that return types with arguments of type ListenableFuture Modifier and Type Method Description static <T> ImmutableList<ListenableFuture<T>>
Futures. inCompletionOrder(java.lang.Iterable<? extends ListenableFuture<? extends T>> futures)
Returns a list of delegate futures that correspond to the futures received in the order that they complete.Methods in com.google.common.util.concurrent with parameters of type ListenableFuture Modifier and Type Method Description static <V> void
Futures. addCallback(ListenableFuture<V> future, FutureCallback<? super V> callback, java.util.concurrent.Executor executor)
Registers separate success and failure callbacks to be run when theFuture
's computation is complete or, if the computation is already complete, immediately.(package private) void
TrustedListenableFutureTask.TrustedFutureInterruptibleAsyncTask. afterRanInterruptibly(ListenableFuture<V> result, java.lang.Throwable error)
static <V> ListenableFuture<java.util.List<V>>
Futures. allAsList(ListenableFuture<? extends V>... futures)
Creates a newListenableFuture
whose value is a list containing the values of all its input futures, if all succeed.static <V,X extends java.lang.Throwable>
ListenableFuture<V>Futures. catching(ListenableFuture<? extends V> input, java.lang.Class<X> exceptionType, Function<? super X,? extends V> fallback, java.util.concurrent.Executor executor)
Returns aFuture
whose result is taken from the given primaryinput
or, if the primary input fails with the givenexceptionType
, from the result provided by thefallback
.static <V,X extends java.lang.Throwable>
ListenableFuture<V>Futures. catchingAsync(ListenableFuture<? extends V> input, java.lang.Class<X> exceptionType, AsyncFunction<? super X,? extends V> fallback, java.util.concurrent.Executor executor)
Returns aFuture
whose result is taken from the given primaryinput
or, if the primary input fails with the givenexceptionType
, from the result provided by thefallback
.(package private) static <V,X extends java.lang.Throwable>
ListenableFuture<V>AbstractCatchingFuture. create(ListenableFuture<? extends V> input, java.lang.Class<X> exceptionType, Function<? super X,? extends V> fallback, java.util.concurrent.Executor executor)
(package private) static <X extends java.lang.Throwable,V>
ListenableFuture<V>AbstractCatchingFuture. create(ListenableFuture<? extends V> input, java.lang.Class<X> exceptionType, AsyncFunction<? super X,? extends V> fallback, java.util.concurrent.Executor executor)
(package private) static <I,O>
ListenableFuture<O>AbstractTransformFuture. create(ListenableFuture<I> input, Function<? super I,? extends O> function, java.util.concurrent.Executor executor)
(package private) static <I,O>
ListenableFuture<O>AbstractTransformFuture. create(ListenableFuture<I> input, AsyncFunction<? super I,? extends O> function, java.util.concurrent.Executor executor)
(package private) static <V> ListenableFuture<V>
TimeoutFuture. create(ListenableFuture<V> delegate, long time, java.util.concurrent.TimeUnit unit, java.util.concurrent.ScheduledExecutorService scheduledExecutor)
static <C extends java.lang.Object & java.lang.AutoCloseable>
ClosingFuture<C>ClosingFuture. eventuallyClosing(ListenableFuture<C> future, java.util.concurrent.Executor closingExecutor)
Deprecated.CreatingFuture
s of closeable types is dangerous in general because the underlying value may never be closed if theFuture
is canceled after its operation begins.static <V> ClosingFuture<V>
ClosingFuture. from(ListenableFuture<V> future)
Starts aClosingFuture
pipeline with aListenableFuture
.static <V> FluentFuture<V>
FluentFuture. from(ListenableFuture<V> future)
Converts the givenListenableFuture
to an equivalentFluentFuture
.private static java.lang.Object
AbstractFuture. getFutureValue(ListenableFuture<?> future)
Returns a value that satisfies the contract of theAbstractFuture.value
field based on the state of given future.static <V> ListenableFuture<V>
Futures. nonCancellationPropagating(ListenableFuture<V> future)
Returns aListenableFuture
whose result is set from the supplied future when it completes.protected boolean
AbstractFuture. setFuture(ListenableFuture<? extends V> future)
Sets the result of thisFuture
to match the supplied inputFuture
once the suppliedFuture
is done, unless thisFuture
has already been cancelled or set (including "set asynchronously," defined below).boolean
SettableFuture. setFuture(ListenableFuture<? extends V> future)
(package private) void
AbstractCatchingFuture.AsyncCatchingFuture. setResult(ListenableFuture<? extends V> result)
(package private) void
AbstractTransformFuture.AsyncTransformFuture. setResult(ListenableFuture<? extends O> result)
(package private) void
CombinedFuture.AsyncCallableInterruptibleTask. setValue(ListenableFuture<V> value)
static <V> ListenableFuture<java.util.List<V>>
Futures. successfulAsList(ListenableFuture<? extends V>... futures)
Creates a newListenableFuture
whose value is a list containing the values of all its successful input futures.static <I,O>
ListenableFuture<O>Futures. transform(ListenableFuture<I> input, Function<? super I,? extends O> function, java.util.concurrent.Executor executor)
Returns a newFuture
whose result is derived from the result of the givenFuture
.static <I,O>
ListenableFuture<O>Futures. transformAsync(ListenableFuture<I> input, AsyncFunction<? super I,? extends O> function, java.util.concurrent.Executor executor)
Returns a newFuture
whose result is asynchronously derived from the result of the givenFuture
.static <V> Futures.FutureCombiner<V>
Futures. whenAllComplete(ListenableFuture<? extends V>... futures)
Creates aFutures.FutureCombiner
that processes the completed futures whether or not they're successful.static <V> Futures.FutureCombiner<V>
Futures. whenAllSucceed(ListenableFuture<? extends V>... futures)
Creates aFutures.FutureCombiner
requiring that all passed in futures are successful.static <V> ListenableFuture<V>
Futures. withTimeout(ListenableFuture<V> delegate, long time, java.util.concurrent.TimeUnit unit, java.util.concurrent.ScheduledExecutorService scheduledExecutor)
Returns a future that delegates to another but will finish early (via aTimeoutException
wrapped in anExecutionException
) if the specified duration expires.static <V> ListenableFuture<V>
Futures. withTimeout(ListenableFuture<V> delegate, java.time.Duration time, java.util.concurrent.ScheduledExecutorService scheduledExecutor)
Returns a future that delegates to another but will finish early (via aTimeoutException
wrapped in anExecutionException
) if the specified duration expires.Method parameters in com.google.common.util.concurrent with type arguments of type ListenableFuture Modifier and Type Method Description static <V> ListenableFuture<java.util.List<V>>
Futures. allAsList(java.lang.Iterable<? extends ListenableFuture<? extends V>> futures)
Creates a newListenableFuture
whose value is a list containing the values of all its input futures, if all succeed.static <T> ImmutableList<ListenableFuture<T>>
Futures. inCompletionOrder(java.lang.Iterable<? extends ListenableFuture<? extends T>> futures)
Returns a list of delegate futures that correspond to the futures received in the order that they complete.static <V> ListenableFuture<java.util.List<V>>
Futures. successfulAsList(java.lang.Iterable<? extends ListenableFuture<? extends V>> futures)
Creates a newListenableFuture
whose value is a list containing the values of all its successful input futures.static <V> Futures.FutureCombiner<V>
Futures. whenAllComplete(java.lang.Iterable<? extends ListenableFuture<? extends V>> futures)
Creates aFutures.FutureCombiner
that processes the completed futures whether or not they're successful.static <V> Futures.FutureCombiner<V>
Futures. whenAllSucceed(java.lang.Iterable<? extends ListenableFuture<? extends V>> futures)
Creates aFutures.FutureCombiner
requiring that all passed in futures are successful.Constructors in com.google.common.util.concurrent with parameters of type ListenableFuture Constructor Description AbstractCatchingFuture(ListenableFuture<? extends V> inputFuture, java.lang.Class<X> exceptionType, F fallback)
AbstractTransformFuture(ListenableFuture<? extends I> inputFuture, F function)
AsyncCatchingFuture(ListenableFuture<? extends V> input, java.lang.Class<X> exceptionType, AsyncFunction<? super X,? extends V> fallback)
AsyncTransformFuture(ListenableFuture<? extends I> inputFuture, AsyncFunction<? super I,? extends O> function)
CatchingFuture(ListenableFuture<? extends V> input, java.lang.Class<X> exceptionType, Function<? super X,? extends V> fallback)
ClosingFuture(ListenableFuture<V> future)
ForwardingFluentFuture(ListenableFuture<V> delegate)
InCompletionOrderState(ListenableFuture<? extends T>[] inputFutures)
ListenableScheduledTask(ListenableFuture<V> listenableDelegate, java.util.concurrent.ScheduledFuture<?> scheduledDelegate)
NonCancellationPropagatingFuture(ListenableFuture<V> delegate)
SetFuture(AbstractFuture<V> owner, ListenableFuture<? extends V> future)
SimpleForwardingListenableFuture(ListenableFuture<V> delegate)
TimeoutFuture(ListenableFuture<V> delegate)
TransformFuture(ListenableFuture<? extends I> inputFuture, Function<? super I,? extends O> function)
Constructor parameters in com.google.common.util.concurrent with type arguments of type ListenableFuture Constructor Description AggregateFuture(ImmutableCollection<? extends ListenableFuture<? extends InputT>> futures, boolean allMustSucceed, boolean collectsValues)
CollectionFuture(ImmutableCollection<? extends ListenableFuture<? extends V>> futures, boolean allMustSucceed)
CombinedFuture(ImmutableCollection<? extends ListenableFuture<?>> futures, boolean allMustSucceed, java.util.concurrent.Executor listenerExecutor, AsyncCallable<V> callable)
CombinedFuture(ImmutableCollection<? extends ListenableFuture<?>> futures, boolean allMustSucceed, java.util.concurrent.Executor listenerExecutor, java.util.concurrent.Callable<V> callable)
FutureCombiner(boolean allMustSucceed, ImmutableList<ListenableFuture<? extends V>> futures)
ListFuture(ImmutableCollection<? extends ListenableFuture<? extends V>> futures, boolean allMustSucceed)
-
Uses of ListenableFuture in com.google.common.util.concurrent.testing
Classes in com.google.common.util.concurrent.testing that implement ListenableFuture Modifier and Type Class Description private static class
SameThreadScheduledExecutorService.ImmediateScheduledFuture<V>
private static class
TestingExecutors.NoOpScheduledExecutorService.NeverScheduledFuture<V>
Fields in com.google.common.util.concurrent.testing declared as ListenableFuture Modifier and Type Field Description protected ListenableFuture<java.lang.Boolean>
AbstractListenableFutureTest. future
private ListenableFuture<?>
MockFutureListener. future
Methods in com.google.common.util.concurrent.testing that return ListenableFuture Modifier and Type Method Description protected abstract <V> ListenableFuture<V>
AbstractListenableFutureTest. createListenableFuture(V value, java.lang.Exception except, java.util.concurrent.CountDownLatch waitOn)
Constructs a listenable future with a value available after the latch has counted down.ListenableFuture<?>
SameThreadScheduledExecutorService. submit(java.lang.Runnable task)
<T> ListenableFuture<T>
SameThreadScheduledExecutorService. submit(java.lang.Runnable task, T result)
<T> ListenableFuture<T>
SameThreadScheduledExecutorService. submit(java.util.concurrent.Callable<T> task)
Constructors in com.google.common.util.concurrent.testing with parameters of type ListenableFuture Constructor Description ImmediateScheduledFuture(ListenableFuture<V> future)
MockFutureListener(ListenableFuture<?> future)
-