@CheckReturnValue @ParametersAreNonnullByDefault
Package com.google.common.util.concurrent
Concurrency utilities.
Commonly used types include ListenableFuture
and
Service
.
Commonly used utilities include Futures
, MoreExecutors
, and ThreadFactoryBuilder
.
This package is a part of the open-source Guava library.
-
Class Summary Class Description AbstractExecutionThreadService Base class for services that can implementAbstractExecutionThreadService.startUp()
,AbstractExecutionThreadService.run()
andAbstractExecutionThreadService.shutDown()
methods.AbstractFuture<V extends @Nullable Object> An abstract implementation ofListenableFuture
, intended for advanced users only.AbstractIdleService Base class for services that do not need a thread while "running" but may need one during startup and shutdown.AbstractListeningExecutorService AbstractListeningExecutorService
implementation that createsListenableFuture
instances for eachRunnable
andCallable
submitted to it.AbstractScheduledService Base class for services that can implementAbstractScheduledService.startUp()
andAbstractScheduledService.shutDown()
but while in the "running" state need to perform a periodic task.AbstractScheduledService.CustomScheduler AAbstractScheduledService.Scheduler
that provides a convenient way for theAbstractScheduledService
to use a dynamically changing schedule.AbstractScheduledService.CustomScheduler.Schedule A value object that represents an absolute delay until a task should be invoked.AbstractScheduledService.Scheduler A scheduler defines the policy for how theAbstractScheduledService
should run its task.AbstractService Base class for implementing services that can handleAbstractService.doStart()
andAbstractService.doStop()
requests, responding to them withAbstractService.notifyStarted()
andAbstractService.notifyStopped()
callbacks.AtomicDouble Adouble
value that may be updated atomically.AtomicDoubleArray Adouble
array in which elements may be updated atomically.AtomicLongMap<K> A map containinglong
values that can be atomically updated.Atomics Static utility methods pertaining to classes in thejava.util.concurrent.atomic
package.Callables Static utility methods pertaining to theCallable
interface.ClosingFuture<V extends @Nullable Object> A step in a pipeline of an asynchronous computation.ClosingFuture.Combiner A builder of aClosingFuture
step that is derived from more than one input step.ClosingFuture.Combiner2<V1 extends @Nullable Object,V2 extends @Nullable Object> A genericClosingFuture.Combiner
that lets you use a lambda or method reference to combine twoClosingFuture
s.ClosingFuture.Combiner3<V1 extends @Nullable Object,V2 extends @Nullable Object,V3 extends @Nullable Object> A genericClosingFuture.Combiner
that lets you use a lambda or method reference to combine threeClosingFuture
s.ClosingFuture.Combiner4<V1 extends @Nullable Object,V2 extends @Nullable Object,V3 extends @Nullable Object,V4 extends @Nullable Object> A genericClosingFuture.Combiner
that lets you use a lambda or method reference to combine fourClosingFuture
s.ClosingFuture.Combiner5<V1 extends @Nullable Object,V2 extends @Nullable Object,V3 extends @Nullable Object,V4 extends @Nullable Object,V5 extends @Nullable Object> A genericClosingFuture.Combiner
that lets you use a lambda or method reference to combine fiveClosingFuture
s.ClosingFuture.DeferredCloser An object that can capture objects to be closed later, when aClosingFuture
pipeline is done.ClosingFuture.Peeker An object that can return the value of theClosingFuture
s that are passed toClosingFuture.whenAllComplete(Iterable)
orClosingFuture.whenAllSucceed(Iterable)
.ClosingFuture.ValueAndCloser<V extends @Nullable Object> An object that holds the final result of an asynchronousClosingFuture
operation and allows the user to close all the closeable objects that were captured during it for later closing.CycleDetectingLockFactory TheCycleDetectingLockFactory
createsReentrantLock
instances andReentrantReadWriteLock
instances that detect potential deadlock by checking for cycles in lock acquisition order.CycleDetectingLockFactory.WithExplicitOrdering<E extends Enum<E>> ACycleDetectingLockFactory.WithExplicitOrdering
provides the additional enforcement of an application-specified ordering of lock acquisitions.ExecutionList A support class forListenableFuture
implementations to manage their listeners.ExecutionSequencer Serializes execution of tasks, somewhat like an "asynchronoussynchronized
block." Each enqueued callable will not be submitted to its associated executor until the previous callable has returned -- and, if the previous callable was anAsyncCallable
, not until theFuture
it returned is done (successful, failed, or cancelled).FakeTimeLimiter A TimeLimiter implementation which actually does not attempt to limit time at all.FluentFuture<V extends @Nullable Object> AListenableFuture
that supports fluent chains of operations.ForwardingBlockingDeque<E> ABlockingDeque
which forwards all its method calls to anotherBlockingDeque
.ForwardingBlockingQueue<E> ABlockingQueue
which forwards all its method calls to anotherBlockingQueue
.ForwardingExecutorService An executor service which forwards all its method calls to another executor service.ForwardingFuture<V extends @Nullable Object> AFuture
which forwards all its method calls to another future.ForwardingFuture.SimpleForwardingFuture<V extends @Nullable Object> A simplified version ofForwardingFuture
where subclasses can pass in an already constructedFuture
as the delegate.ForwardingListenableFuture<V extends @Nullable Object> AListenableFuture
which forwards all its method calls to another future.ForwardingListenableFuture.SimpleForwardingListenableFuture<V extends @Nullable Object> A simplified version ofForwardingListenableFuture
where subclasses can pass in an already constructedListenableFuture
as the delegate.ForwardingListeningExecutorService A listening executor service which forwards all its method calls to another listening executor service.Futures Static utility methods pertaining to theFuture
interface.Futures.FutureCombiner<V extends @Nullable Object> A helper to create a newListenableFuture
whose result is generated from a combination of input futures.JdkFutureAdapters Utilities necessary for working with libraries that supply plainFuture
instances.ListenableFutureTask<V extends @Nullable Object> AFutureTask
that also implements theListenableFuture
interface.Monitor A synchronization abstraction supporting waiting on arbitrary boolean conditions.Monitor.Guard A boolean condition for which a thread may wait.MoreExecutors RateLimiter A rate limiter.Runnables Static utility methods pertaining to theRunnable
interface.Service.Listener A listener for the various state changes that aService
goes through in its lifecycle.ServiceManager A manager for monitoring and controlling a set of services.ServiceManager.Listener A listener for the aggregate state changes of the services that are under management.SettableFuture<V extends @Nullable Object> AListenableFuture
whose result can be set by aSettableFuture.set(Object)
,SettableFuture.setException(Throwable)
orSettableFuture.setFuture(ListenableFuture)
call.SimpleTimeLimiter A TimeLimiter that runs method calls in the background using anExecutorService
.Striped<L> A stripedLock/Semaphore/ReadWriteLock
.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 factoryUncaughtExceptionHandlers Factories forThread.UncaughtExceptionHandler
instances.Uninterruptibles Utilities for treating interruptible operations as uninterruptible. -
Enum Summary Enum Description CycleDetectingLockFactory.Policies Pre-definedCycleDetectingLockFactory.Policy
implementations.Service.State The lifecycle states of a service. -
Exception Summary Exception Description CycleDetectingLockFactory.PotentialDeadlockException Represents a detected cycle in lock acquisition ordering.UncheckedExecutionException Unchecked variant ofExecutionException
.UncheckedTimeoutException Unchecked version ofTimeoutException
. -
Error Summary Error Description ExecutionError Error
variant ofExecutionException
.