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.

Uses of ListenableFuture in com.google.common.cache

Methods in com.google.common.cache that return ListenableFuture

Modifier and Type	Method	Description
ListenableFuture<V>	CacheLoader.reload(K key, V oldValue)	Computes or retrieves a replacement value corresponding to an already-cached key.

Uses of ListenableFuture in com.google.common.util.concurrent

Subinterfaces of ListenableFuture in com.google.common.util.concurrent

Modifier and Type	Interface	Description
interface	CheckedFuture<V,X extends java.lang.Exception>	A CheckedFuture is a ListenableFuture that includes versions of the get methods that can throw a checked exception.
interface	ListenableScheduledFuture<V>	Helper interface to implement both ListenableFuture and ScheduledFuture.

Classes in com.google.common.util.concurrent that implement ListenableFuture

Modifier and Type	Class	Description
class	AbstractCheckedFuture<V,X extends java.lang.Exception>	A delegating wrapper around a ListenableFuture that adds support for the AbstractCheckedFuture.checkedGet() and AbstractCheckedFuture.checkedGet(long, TimeUnit) methods.
class	AbstractFuture<V>	An abstract implementation of ListenableFuture, intended for advanced users only.
class	ForwardingCheckedFuture<V,X extends java.lang.Exception>	A future which forwards all its method calls to another future.
static class	ForwardingCheckedFuture.SimpleForwardingCheckedFuture<V,X extends java.lang.Exception>	A simplified version of ForwardingCheckedFuture where subclasses can pass in an already constructed CheckedFuture as the delegate.
class	ForwardingListenableFuture<V>	A ListenableFuture which forwards all its method calls to another future.
static class	ForwardingListenableFuture.SimpleForwardingListenableFuture<V>	A simplified version of ForwardingListenableFuture where subclasses can pass in an already constructed ListenableFuture as the delegate.
class	ListenableFutureTask<V>	A FutureTask that also implements the ListenableFuture interface.
class	SettableFuture<V>	A ListenableFuture whose result may be set by a SettableFuture.set(Object), SettableFuture.setException(Throwable) or SettableFuture.setFuture(ListenableFuture) call.

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 new ListenableFuture 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 new ListenableFuture whose value is a list containing the values of all its input futures, if all succeed.
ListenableFuture<O>	AsyncFunction.apply(I input)	Returns an output Future to use in place of the given input.
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)	Returns a Future whose result is taken from the given primary input or, if the primary input fails with the given exceptionType, from the result provided by the fallback.
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 a Future whose result is taken from the given primary input or, if the primary input fails with the given exceptionType, from the result provided by the fallback.
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)	Returns a Future whose result is taken from the given primary input or, if the primary input fails with the given exceptionType, from the result provided by the fallback.
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 a Future whose result is taken from the given primary input or, if the primary input fails with the given exceptionType, from the result provided by the fallback.
ListenableFuture<V>	FutureFallback.create(java.lang.Throwable t)	Deprecated. Returns a Future to be used in place of the Future that failed with the given exception.
protected abstract ListenableFuture<V>	ForwardingListenableFuture.delegate()
protected ListenableFuture<V>	ForwardingListenableFuture.SimpleForwardingListenableFuture.delegate()
static <V> ListenableFuture<V>	Futures.dereference(ListenableFuture<? extends ListenableFuture<? extends V>> nested)	Returns a new ListenableFuture whose result is the product of calling get() on the Future nested within the given Future, effectively chaining the futures one after the other.
static <V> ListenableFuture<V>	Futures.immediateCancelledFuture()	Creates a ListenableFuture which is cancelled immediately upon construction, so that isCancelled() always returns true.
static <V> ListenableFuture<V>	Futures.immediateFailedFuture(java.lang.Throwable throwable)	Returns a ListenableFuture which has an exception set immediately upon construction.
static <V> ListenableFuture<V>	Futures.immediateFuture(V value)	Creates a ListenableFuture which has its value set immediately upon construction.
static <V> ListenableFuture<V>	JdkFutureAdapters.listenInPoolThread(java.util.concurrent.Future<V> future)	Assigns a thread to the given Future to provide ListenableFuture functionality.
static <V> ListenableFuture<V>	JdkFutureAdapters.listenInPoolThread(java.util.concurrent.Future<V> future, java.util.concurrent.Executor executor)	Submits a blocking task for the given Future to provide ListenableFuture functionality.
static <V> ListenableFuture<V>	Futures.nonCancellationPropagating(ListenableFuture<V> future)	Creates a new ListenableFuture whose result is set from the supplied future when it completes.
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)
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)
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)
static <V> ListenableFuture<java.util.List<V>>	Futures.successfulAsList(ListenableFuture<? extends V>... futures)	Creates a new ListenableFuture 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 new ListenableFuture 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)	Returns a new ListenableFuture whose result is the product of applying the given Function to the result of the given Future.
static <I,O> ListenableFuture<O>	Futures.transform(ListenableFuture<I> input, Function<? super I,? extends O> function, java.util.concurrent.Executor executor)	Returns a new ListenableFuture whose result is the product of applying the given Function to the result of the given Future.
static <I,O> ListenableFuture<O>	Futures.transform(ListenableFuture<I> input, AsyncFunction<? super I,? extends O> function)	Deprecated. These AsyncFunction overloads of transform are being renamed to transformAsync.
static <I,O> ListenableFuture<O>	Futures.transform(ListenableFuture<I> input, AsyncFunction<? super I,? extends O> function, java.util.concurrent.Executor executor)	Deprecated. These AsyncFunction overloads of transform are being renamed to transformAsync.
static <I,O> ListenableFuture<O>	Futures.transformAsync(ListenableFuture<I> input, AsyncFunction<? super I,? extends O> function)	Returns a new ListenableFuture whose result is asynchronously derived from the result of the given Future.
static <I,O> ListenableFuture<O>	Futures.transformAsync(ListenableFuture<I> input, AsyncFunction<? super I,? extends O> function, java.util.concurrent.Executor executor)	Returns a new ListenableFuture whose result is asynchronously derived from the result of the given Future.
static <V> ListenableFuture<V>	Futures.withFallback(ListenableFuture<? extends V> input, FutureFallback<? extends V> fallback)	Deprecated. Use catchingAsync(input, Throwable.class, fallbackImplementedAsAnAsyncFunction), usually replacing Throwable.class with the specific type you want to handle.
static <V> ListenableFuture<V>	Futures.withFallback(ListenableFuture<? extends V> input, FutureFallback<? extends V> fallback, java.util.concurrent.Executor executor)	Deprecated. Use catchingAsync(input, Throwable.class, fallbackImplementedAsAnAsyncFunction, executor), usually replacing Throwable.class with the specific type you want to handle.
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 a TimeoutException wrapped in an ExecutionException) 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)	Registers separate success and failure callbacks to be run when the Future's computation is complete or, if the computation is already complete, immediately.
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 the Future's computation is complete or, if the computation is already complete, immediately.
static <V> ListenableFuture<java.util.List<V>>	Futures.allAsList(ListenableFuture<? extends V>... futures)	Creates a new ListenableFuture 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)	Returns a Future whose result is taken from the given primary input or, if the primary input fails with the given exceptionType, from the result provided by the fallback.
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 a Future whose result is taken from the given primary input or, if the primary input fails with the given exceptionType, from the result provided by the fallback.
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)	Returns a Future whose result is taken from the given primary input or, if the primary input fails with the given exceptionType, from the result provided by the fallback.
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 a Future whose result is taken from the given primary input or, if the primary input fails with the given exceptionType, from the result provided by the fallback.
static <V> ListenableFuture<V>	Futures.dereference(ListenableFuture<? extends ListenableFuture<? extends V>> nested)	Returns a new ListenableFuture whose result is the product of calling get() on the Future nested within the given Future, effectively chaining the futures one after the other.
static <V,X extends java.lang.Exception> CheckedFuture<V,X>	Futures.makeChecked(ListenableFuture<V> future, Function<? super java.lang.Exception,X> mapper)	Creates a CheckedFuture out of a normal ListenableFuture and a Function that maps from Exception instances into the appropriate checked type.
static <V> ListenableFuture<V>	Futures.nonCancellationPropagating(ListenableFuture<V> future)	Creates a new ListenableFuture whose result is set from the supplied future when it completes.
protected boolean	AbstractFuture.setFuture(ListenableFuture<? extends V> future)	Sets the result of this Future to match the supplied input Future once the supplied Future is done, unless this Future has already been cancelled or set (including "set asynchronously," defined below).
boolean	SettableFuture.setFuture(ListenableFuture<? extends V> future)
static <V> ListenableFuture<java.util.List<V>>	Futures.successfulAsList(ListenableFuture<? extends V>... futures)	Creates a new ListenableFuture 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)	Returns a new ListenableFuture whose result is the product of applying the given Function to the result of the given Future.
static <I,O> ListenableFuture<O>	Futures.transform(ListenableFuture<I> input, Function<? super I,? extends O> function, java.util.concurrent.Executor executor)	Returns a new ListenableFuture whose result is the product of applying the given Function to the result of the given Future.
static <I,O> ListenableFuture<O>	Futures.transform(ListenableFuture<I> input, AsyncFunction<? super I,? extends O> function)	Deprecated. These AsyncFunction overloads of transform are being renamed to transformAsync.
static <I,O> ListenableFuture<O>	Futures.transform(ListenableFuture<I> input, AsyncFunction<? super I,? extends O> function, java.util.concurrent.Executor executor)	Deprecated. These AsyncFunction overloads of transform are being renamed to transformAsync.
static <I,O> ListenableFuture<O>	Futures.transformAsync(ListenableFuture<I> input, AsyncFunction<? super I,? extends O> function)	Returns a new ListenableFuture whose result is asynchronously derived from the result of the given Future.
static <I,O> ListenableFuture<O>	Futures.transformAsync(ListenableFuture<I> input, AsyncFunction<? super I,? extends O> function, java.util.concurrent.Executor executor)	Returns a new ListenableFuture whose result is asynchronously derived from the result of the given Future.
static <V> ListenableFuture<V>	Futures.withFallback(ListenableFuture<? extends V> input, FutureFallback<? extends V> fallback)	Deprecated. Use catchingAsync(input, Throwable.class, fallbackImplementedAsAnAsyncFunction), usually replacing Throwable.class with the specific type you want to handle.
static <V> ListenableFuture<V>	Futures.withFallback(ListenableFuture<? extends V> input, FutureFallback<? extends V> fallback, java.util.concurrent.Executor executor)	Deprecated. Use catchingAsync(input, Throwable.class, fallbackImplementedAsAnAsyncFunction, executor), usually replacing Throwable.class with the specific type you want to handle.
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 a TimeoutException wrapped in an ExecutionException) 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 new ListenableFuture whose value is a list containing the values of all its input futures, if all succeed.
static <V> ListenableFuture<V>	Futures.dereference(ListenableFuture<? extends ListenableFuture<? extends V>> nested)	Returns a new ListenableFuture whose result is the product of calling get() on the Future nested within the given Future, effectively chaining the futures one after the other.
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 new ListenableFuture whose value is a list containing the values of all its successful input futures.

Constructors in com.google.common.util.concurrent with parameters of type ListenableFuture

Constructor	Description
AbstractCheckedFuture(ListenableFuture<V> delegate)	Constructs an AbstractCheckedFuture that wraps a delegate.
SimpleForwardingListenableFuture(ListenableFuture<V> delegate)