Overview   Package  Class  Use  Tree  Deprecated  Index  Help 
 PREV PACKAGE   NEXT PACKAGE FRAMES    NO FRAMES    
@ParametersAreNonnullByDefault

Package com.google.common.util.concurrent

Concurrency utilities.

See:
          Description

Interface Summary
CheckedFuture<V,X extends Exception> A CheckedFuture is an extension of Future that includes versions of the get methods that can throw a checked exception and allows listeners to be attached to the future.
ListenableFuture<V> A Future that accepts completion listeners.
Service An object with an operational state, plus asynchronous Service.start() and Service.stop() lifecycle methods to transfer into and out of this state.
TimeLimiter Produces proxies that impose a time limit on method calls to the proxied object.
UninterruptibleFuture<V> A Future whose get calls cannot be interrupted.
 

Class Summary
AbstractCheckedFuture<V,X extends Exception> A delegating wrapper around a ListenableFuture that adds support for the AbstractCheckedFuture.checkedGet() and AbstractCheckedFuture.checkedGet(long, TimeUnit) methods.
AbstractExecutionThreadService Base class for services that can implement AbstractExecutionThreadService.startUp(), AbstractExecutionThreadService.run() and AbstractExecutionThreadService.shutDown() methods.
AbstractFuture<V> An abstract implementation of the Future interface.
AbstractIdleService Base class for services that do not need a thread while "running" but may need one during startup and shutdown.
AbstractListenableFuture<V> An abstract base implementation of the listener support provided by ListenableFuture.
AbstractService Base class for implementing services that can handle AbstractService.doStart() and AbstractService.doStop() requests, responding to them with AbstractService.notifyStarted() and AbstractService.notifyStopped() callbacks.
Callables Static utility methods pertaining to the Callable interface.
ExecutionList A list of (Runnable, Executor) pairs that guarantees that every Runnable that is added using the add method will be executed in its associated Executor after ExecutionList.run() is called.
FakeTimeLimiter A TimeLimiter implementation which actually does not attempt to limit time at all.
ForwardingBlockingQueue<E> A BlockingQueue which forwards all its method calls to another BlockingQueue.
ForwardingCheckedFuture<V,X extends Exception> A future which forwards all its method calls to another future.
ForwardingCheckedFuture.SimpleForwardingCheckedFuture<V,X extends Exception> A simplified version of ForwardingCheckedFuture where subclasses can pass in an already constructed CheckedFuture as the delegate.
ForwardingFuture<V> A ForwardingFuture.SimpleForwardingFuture which forwards all its method calls to another future.
ForwardingFuture.SimpleForwardingFuture<V> A simplified version of ForwardingFuture where subclasses can pass in an already constructed Future as the delegate.
ForwardingListenableFuture<V> A ForwardingListenableFuture.SimpleForwardingListenableFuture which forwards all its method calls to another future.
ForwardingListenableFuture.SimpleForwardingListenableFuture<V> A simplified version of ForwardingListenableFuture where subclasses can pass in an already constructed ListenableFuture as the delegate.
ForwardingService A Service that forwards all method calls to another service.
Futures Static utility methods pertaining to the Future interface.
ListenableFutureTask<V> A FutureTask that also implements the ListenableFuture interface.
MoreExecutors Factory and utility methods for Executor, ExecutorService, and ThreadFactory.
SettableFuture<V> A ListenableFuture whose result may be set by a SettableFuture.set(Object) or SettableFuture.setException(Throwable) call.
SimpleTimeLimiter A TimeLimiter that runs method calls in the background using an ExecutorService.
ThreadFactoryBuilder A ThreadFactory builder, providing any combination of these features: whether threads should be marked as daemon threads a naming format a thread priority an uncaught exception handler a backing thread factory If no backing thread factory is provided, a default backing thread factory is used as if by calling setThreadFactory(Executors.defaultThreadFactory()).
UncaughtExceptionHandlers Factories for Thread.UncaughtExceptionHandler instances.
 

Enum Summary
Service.State The lifecycle states of a service.
 

Exception Summary
UncheckedTimeoutException Unchecked version of TimeoutException.
 

Package com.google.common.util.concurrent Description

Concurrency utilities.

This package is a part of the open-source Guava libraries.

Overview   Package  Class  Use  Tree  Deprecated  Index  Help 
 PREV PACKAGE   NEXT PACKAGE FRAMES    NO FRAMES