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

Packages that use ListenableFuture
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
 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
 interface CheckedFuture<V,X extends Exception>
          A CheckedFuture is a ListenableFuture that includes versions of the get methods that can throw a checked exception.
 

Classes in com.google.common.util.concurrent that implement ListenableFuture
 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 ForwardingListenableFuture.SimpleForwardingListenableFuture 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.
 

Methods in com.google.common.util.concurrent that return ListenableFuture
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.
protected abstract  ListenableFuture<V> ForwardingListenableFuture.delegate()
           
protected  ListenableFuture<V> ForwardingListenableFuture.SimpleForwardingListenableFuture.delegate()
           
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.
 ListenableFuture<Service.State> ForwardingService.start()
           
 ListenableFuture<Service.State> AbstractIdleService.start()
           
 ListenableFuture<Service.State> AbstractExecutionThreadService.start()
           
 ListenableFuture<Service.State> AbstractScheduledService.start()
           
 ListenableFuture<Service.State> AbstractService.start()
           
 ListenableFuture<Service.State> Service.start()
          If the service state is Service.State.NEW, this initiates service startup and returns immediately.
 ListenableFuture<Service.State> ForwardingService.stop()
           
 ListenableFuture<Service.State> AbstractIdleService.stop()
           
 ListenableFuture<Service.State> AbstractExecutionThreadService.stop()
           
 ListenableFuture<Service.State> AbstractScheduledService.stop()
           
 ListenableFuture<Service.State> AbstractService.stop()
           
 ListenableFuture<Service.State> Service.stop()
          If the service is starting or running, this initiates service shutdown and returns immediately.
<T> ListenableFuture<T>
ListeningExecutorService.submit(Callable<T> task)
           
<T> ListenableFuture<T>
ForwardingListeningExecutorService.submit(Callable<T> task)
           
 ListenableFuture<?> ListeningExecutorService.submit(Runnable task)
           
 ListenableFuture<?> ForwardingListeningExecutorService.submit(Runnable task)
           
<T> ListenableFuture<T>
ListeningExecutorService.submit(Runnable task, T result)
           
<T> ListenableFuture<T>
ForwardingListeningExecutorService.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.
 

Methods in com.google.common.util.concurrent with parameters of type ListenableFuture
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 Exception>
CheckedFuture<V,X>
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<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.
 

Method parameters in com.google.common.util.concurrent with type arguments of type ListenableFuture
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.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.
 

Constructors in com.google.common.util.concurrent with parameters of type ListenableFuture
AbstractCheckedFuture(ListenableFuture<V> delegate)
          Constructs an AbstractCheckedFuture that wraps a delegate.
ForwardingListenableFuture.SimpleForwardingListenableFuture(ListenableFuture<V> delegate)
           
 



Copyright © 2010-2012. All Rights Reserved.