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 the
ListenableFuture interface. |
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)
or SettableFuture.setException(Throwable) 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 . |
ListenableFuture<V> |
FutureFallback.create(Throwable t)
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. |
ListenableFuture<Service.State> |
AbstractExecutionThreadService.start()
Deprecated.
|
ListenableFuture<Service.State> |
ForwardingService.start()
Deprecated.
|
ListenableFuture<Service.State> |
Service.start()
Deprecated.
Use
Service.startAsync() instead of this method to start the Service or
use a Service.Listener to asynchronously wait for service startup. |
ListenableFuture<Service.State> |
AbstractService.start()
Deprecated.
|
ListenableFuture<Service.State> |
AbstractIdleService.start()
Deprecated.
|
ListenableFuture<Service.State> |
AbstractScheduledService.start()
Deprecated.
|
ListenableFuture<Service.State> |
AbstractExecutionThreadService.stop()
Deprecated.
|
ListenableFuture<Service.State> |
ForwardingService.stop()
Deprecated.
|
ListenableFuture<Service.State> |
Service.stop()
Deprecated.
Use
Service.stopAsync() instead of this method to initiate service shutdown or use a
service Service.Listener to asynchronously wait for service shutdown. |
ListenableFuture<Service.State> |
AbstractService.stop()
Deprecated.
|
ListenableFuture<Service.State> |
AbstractIdleService.stop()
Deprecated.
|
ListenableFuture<Service.State> |
AbstractScheduledService.stop()
Deprecated.
|
<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)
Returns a new
ListenableFuture whose result is asynchronously
derived from the result of the given Future . |
static <I,O> ListenableFuture<O> |
Futures.transform(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 <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 <V> ListenableFuture<V> |
Futures.withFallback(ListenableFuture<? extends V> input,
FutureFallback<? extends V> fallback)
Returns a
Future whose result is taken from the given primary
input or, if the primary input fails, from the Future
provided by the fallback . |
static <V> ListenableFuture<V> |
Futures.withFallback(ListenableFuture<? extends V> input,
FutureFallback<? extends V> fallback,
Executor executor)
Returns a
Future whose result is taken from the given primary
input or, if the primary input fails, from the Future
provided by the fallback . |
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> 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<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. |
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)
Returns a new
ListenableFuture whose result is asynchronously
derived from the result of the given Future . |
static <I,O> ListenableFuture<O> |
Futures.transform(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 <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 <V> ListenableFuture<V> |
Futures.withFallback(ListenableFuture<? extends V> input,
FutureFallback<? extends V> fallback)
Returns a
Future whose result is taken from the given primary
input or, if the primary input fails, from the Future
provided by the fallback . |
static <V> ListenableFuture<V> |
Futures.withFallback(ListenableFuture<? extends V> input,
FutureFallback<? extends V> fallback,
Executor executor)
Returns a
Future whose result is taken from the given primary
input or, if the primary input fails, from the Future
provided by the fallback . |
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 <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-2013. All Rights Reserved.