| Package | Description |
|---|---|
| com.google.common.cache |
This package contains caching utilities.
|
| com.google.common.util.concurrent |
Concurrency utilities.
|
| Modifier and Type | Method and Description |
|---|---|
ListenableFuture<V> |
CacheLoader.reload(K key,
V oldValue)
Computes or retrieves a replacement value corresponding to an already-cached
key. |
| Modifier and Type | Interface and Description |
|---|---|
interface |
CheckedFuture<V,X extends 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. |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractCheckedFuture<V,X extends 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 Exception>
A future which forwards all its method calls to another future.
|
static class |
ForwardingCheckedFuture.SimpleForwardingCheckedFuture<V,X extends 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. |
| Modifier and Type | Method and Description |
|---|---|
static <V> ListenableFuture<List<V>> |
Futures.allAsList(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<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. |
ListenableFuture<O> |
AsyncFunction.apply(I input)
Returns an output
Future to use in place of the given input. |
static <V,X extends Throwable> |
Futures.catching(ListenableFuture<? extends V> input,
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 Throwable> |
Futures.catching(ListenableFuture<? extends V> input,
Class<X> exceptionType,
Function<? super X,? extends V> fallback,
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 Throwable> |
Futures.catchingAsync(ListenableFuture<? extends V> input,
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 Throwable> |
Futures.catchingAsync(ListenableFuture<? extends V> input,
Class<X> exceptionType,
AsyncFunction<? super X,? extends V> fallback,
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(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(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(Future<V> future)
Assigns a thread to the given
Future to provide ListenableFuture functionality. |
static <V> ListenableFuture<V> |
JdkFutureAdapters.listenInPoolThread(Future<V> future,
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. |
<T> ListenableFuture<T> |
ForwardingListeningExecutorService.submit(Callable<T> task) |
<T> ListenableFuture<T> |
ListeningExecutorService.submit(Callable<T> task) |
<T> ListenableFuture<T> |
AbstractListeningExecutorService.submit(Callable<T> task) |
ListenableFuture<?> |
ForwardingListeningExecutorService.submit(Runnable task) |
ListenableFuture<?> |
ListeningExecutorService.submit(Runnable task) |
ListenableFuture<?> |
AbstractListeningExecutorService.submit(Runnable task) |
<T> ListenableFuture<T> |
ForwardingListeningExecutorService.submit(Runnable task,
T result) |
<T> ListenableFuture<T> |
ListeningExecutorService.submit(Runnable task,
T result) |
<T> ListenableFuture<T> |
AbstractListeningExecutorService.submit(Runnable task,
T result) |
static <V> ListenableFuture<List<V>> |
Futures.successfulAsList(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 <V> ListenableFuture<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,
AsyncFunction<? super I,? extends O> function)
Deprecated.
These
AsyncFunction overloads of transform are
being renamed to transformAsync. (The Function
overloads are keeping the "transform" name.) This method will be removed in Guava release
20.0. |
static <I,O> ListenableFuture<O> |
Futures.transform(ListenableFuture<I> input,
AsyncFunction<? super I,? extends O> function,
Executor executor)
Deprecated.
These
AsyncFunction overloads of transform are
being renamed to transformAsync. (The Function
overloads are keeping the "transform" name.) This method will be removed in Guava release
20.0. |
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,
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.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,
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. This method
will be removed in Guava release 20.0. |
static <V> ListenableFuture<V> |
Futures.withFallback(ListenableFuture<? extends V> input,
FutureFallback<? extends V> fallback,
Executor executor)
Deprecated.
Use
catchingAsync(input, Throwable.class,
fallbackImplementedAsAnAsyncFunction, executor), usually replacing
Throwable.class with the specific type you want to handle. This method
will be removed in Guava release 20.0. |
static <V> ListenableFuture<V> |
Futures.withTimeout(ListenableFuture<V> delegate,
long time,
TimeUnit unit,
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. |
| Modifier and Type | Method and Description |
|---|---|
static <T> ImmutableList<ListenableFuture<T>> |
Futures.inCompletionOrder(Iterable<? extends ListenableFuture<? extends T>> futures)
Returns a list of delegate futures that correspond to the futures received in the order
that they complete.
|
| Modifier and Type | Method and 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,
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<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 Throwable> |
Futures.catching(ListenableFuture<? extends V> input,
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 Throwable> |
Futures.catching(ListenableFuture<? extends V> input,
Class<X> exceptionType,
Function<? super X,? extends V> fallback,
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 Throwable> |
Futures.catchingAsync(ListenableFuture<? extends V> input,
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 Throwable> |
Futures.catchingAsync(ListenableFuture<? extends V> input,
Class<X> exceptionType,
AsyncFunction<? super X,? extends V> fallback,
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 Exception> |
Futures.makeChecked(ListenableFuture<V> future,
Function<? super 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. |
boolean |
SettableFuture.setFuture(ListenableFuture<? extends V> future) |
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). |
static <V> ListenableFuture<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,
AsyncFunction<? super I,? extends O> function)
Deprecated.
These
AsyncFunction overloads of transform are
being renamed to transformAsync. (The Function
overloads are keeping the "transform" name.) This method will be removed in Guava release
20.0. |
static <I,O> ListenableFuture<O> |
Futures.transform(ListenableFuture<I> input,
AsyncFunction<? super I,? extends O> function,
Executor executor)
Deprecated.
These
AsyncFunction overloads of transform are
being renamed to transformAsync. (The Function
overloads are keeping the "transform" name.) This method will be removed in Guava release
20.0. |
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,
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.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,
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. This method
will be removed in Guava release 20.0. |
static <V> ListenableFuture<V> |
Futures.withFallback(ListenableFuture<? extends V> input,
FutureFallback<? extends V> fallback,
Executor executor)
Deprecated.
Use
catchingAsync(input, Throwable.class,
fallbackImplementedAsAnAsyncFunction, executor), usually replacing
Throwable.class with the specific type you want to handle. This method
will be removed in Guava release 20.0. |
static <V> ListenableFuture<V> |
Futures.withTimeout(ListenableFuture<V> delegate,
long time,
TimeUnit unit,
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. |
| Modifier and Type | Method and Description |
|---|---|
static <V> ListenableFuture<List<V>> |
Futures.allAsList(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(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<List<V>> |
Futures.successfulAsList(Iterable<? extends ListenableFuture<? extends V>> futures)
Creates a new
ListenableFuture whose value is a list containing the
values of all its successful input futures. |
| Constructor and Description |
|---|
AbstractCheckedFuture(ListenableFuture<V> delegate)
Constructs an
AbstractCheckedFuture that wraps a delegate. |
ForwardingListenableFuture.SimpleForwardingListenableFuture(ListenableFuture<V> delegate) |
Copyright © 2010-2015. All Rights Reserved.