Package | Description |
---|---|
com.google.common.cache |
This package contains caching utilities.
|
com.google.common.util.concurrent |
Concurrency utilities.
|
com.google.common.util.concurrent.testing |
Class and Description |
---|
ListenableFuture
A
Future that accepts completion listeners. |
SettableFuture
A
ListenableFuture whose result can be set by a SettableFuture.set(Object) , SettableFuture.setException(Throwable) or SettableFuture.setFuture(ListenableFuture) call. |
Class and Description |
---|
AbstractCatchingFuture
Implementations of
Futures.catching* . |
AbstractCheckedFuture
Deprecated.
CheckedFuture cannot properly support the chained operations that are the
primary goal of ListenableFuture . CheckedFuture also encourages users to
rethrow exceptions from one thread in another thread, producing misleading stack traces.
Additionally, it has a surprising policy about which exceptions to map and which to leave
untouched. Guava users who want a CheckedFuture can fork the classes for their own
use, possibly specializing them to the particular exception type they use. We recommend that
most people use ListenableFuture and perform any exception wrapping themselves. This
class is scheduled for removal from Guava in February 2018. |
AbstractFuture
An abstract implementation of
ListenableFuture , intended for advanced users only. |
AbstractFuture.AtomicHelper |
AbstractFuture.Cancellation
A special value to represent cancellation and the 'wasInterrupted' bit.
|
AbstractFuture.Failure
A special value to represent failure, when
AbstractFuture.setException(java.lang.Throwable) is called successfully. |
AbstractFuture.Listener
Listeners also form a stack through the
AbstractFuture.listeners field. |
AbstractFuture.TrustedFuture
A less abstract subclass of AbstractFuture.
|
AbstractFuture.Waiter
Waiter links form a Treiber stack, in the
AbstractFuture.waiters field. |
AbstractListeningExecutorService
Abstract
ListeningExecutorService implementation that creates ListenableFuture
instances for each Runnable and Callable submitted to it. |
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 the
AbstractScheduledService should run its
task. |
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. |
AbstractService.StateSnapshot
An immutable snapshot of the current state of the service.
|
AbstractTransformFuture
Implementations of
Futures.transform* . |
AggregateFuture
A future made up of a collection of sub-futures.
|
AggregateFuture.RunningState |
AggregateFutureState
A helper which does some thread-safe operations for aggregate futures, which must be implemented
differently in GWT.
|
AggregateFutureState.AtomicHelper |
AsyncCallable
Computes a value, possibly asynchronously.
|
AsyncFunction
Transforms a value, possibly asynchronously.
|
AtomicDouble
A
double value that may be updated atomically. |
AtomicLongMap
A map containing
long values that can be atomically updated. |
CheckedFuture
Deprecated.
CheckedFuture cannot properly support the chained operations that are the
primary goal of ListenableFuture . CheckedFuture also encourages users to
rethrow exceptions from one thread in another thread, producing misleading stack traces.
Additionally, it has a surprising policy about which exceptions to map and which to leave
untouched. Guava users who want a CheckedFuture can fork the classes for their own
use, possibly specializing them to the particular exception type they use. We recommend that
most people use ListenableFuture and perform any exception wrapping themselves. This
class is scheduled for removal from Guava in February 2018. |
CollectionFuture
Aggregate future that collects (stores) results of each future.
|
CollectionFuture.CollectionFutureRunningState |
CombinedFuture.CombinedFutureInterruptibleTask |
CycleDetectingLockFactory
The
CycleDetectingLockFactory creates ReentrantLock instances and ReentrantReadWriteLock instances that detect potential deadlock by checking for cycles in lock
acquisition order. |
CycleDetectingLockFactory.CycleDetectingLock
Internal Lock implementations implement the
CycleDetectingLock interface, allowing the
detection logic to treat all locks in the same manner. |
CycleDetectingLockFactory.CycleDetectingReentrantReadLock |
CycleDetectingLockFactory.CycleDetectingReentrantReadWriteLock |
CycleDetectingLockFactory.CycleDetectingReentrantWriteLock |
CycleDetectingLockFactory.ExampleStackTrace
A Throwable used to record a stack trace that illustrates an example of a specific lock
acquisition ordering.
|
CycleDetectingLockFactory.LockGraphNode
A
LockGraphNode associated with each lock instance keeps track of the directed edges in
the lock acquisition graph. |
CycleDetectingLockFactory.Policies
Pre-defined
CycleDetectingLockFactory.Policy implementations. |
CycleDetectingLockFactory.Policy
Encapsulates the action to be taken when a potential deadlock is encountered.
|
CycleDetectingLockFactory.PotentialDeadlockException
Represents a detected cycle in lock acquisition ordering.
|
CycleDetectingLockFactory.WithExplicitOrdering
A
CycleDetectingLockFactory.WithExplicitOrdering provides the additional enforcement of
an application-specified ordering of lock acquisitions. |
ExecutionList
A support class for
ListenableFuture implementations to manage their listeners. |
ExecutionList.RunnableExecutorPair |
FluentFuture
A
ListenableFuture that supports fluent chains of operations. |
ForwardingCheckedFuture
Deprecated.
CheckedFuture cannot properly support the chained operations that are the
primary goal of ListenableFuture . CheckedFuture also encourages users to
rethrow exceptions from one thread in another thread, producing misleading stack traces.
Additionally, it has a surprising policy about which exceptions to map and which to leave
untouched. Guava users who want a CheckedFuture can fork the classes for their own
use, possibly specializing them to the particular exception type they use. We recommend that
most people use ListenableFuture and perform any exception wrapping themselves. This
class is scheduled for removal from Guava in February 2018. |
ForwardingCondition
Forwarding wrapper around a
Condition . |
ForwardingExecutorService
An executor service which forwards all its method calls to another executor service.
|
ForwardingFuture
A
Future which forwards all its method calls to another future. |
ForwardingListenableFuture
A
ListenableFuture which forwards all its method calls to another future. |
ForwardingListenableFuture.SimpleForwardingListenableFuture
A simplified version of
ForwardingListenableFuture where subclasses can pass in an
already constructed ListenableFuture as the delegate. |
ForwardingLock
Forwarding wrapper around a
Lock . |
FutureCallback
A callback for accepting the results of a
Future computation
asynchronously. |
Futures.FutureCombiner
A helper to create a new
ListenableFuture whose result is generated from a combination
of input futures. |
Futures.InCompletionOrderState |
FuturesGetChecked.GetCheckedTypeValidator |
FuturesGetChecked.GetCheckedTypeValidatorHolder.ClassValueValidator |
FuturesGetChecked.GetCheckedTypeValidatorHolder.WeakSetValidator |
GwtFluentFutureCatchingSpecialization
Hidden superclass of
FluentFuture that provides us a place to declare special GWT
versions of the FluentFuture.catching family of methods. |
GwtFuturesCatchingSpecialization
Hidden superclass of
Futures that provides us a place to declare special GWT versions of
the Futures.catching family of methods. |
ImmediateFuture
Implementations of
Futures.immediate* . |
ImmediateFuture.ImmediateSuccessfulFuture |
InterruptibleTask |
ListenableFuture
A
Future that accepts completion listeners. |
ListenableFutureTask
A
FutureTask that also implements the ListenableFuture interface. |
ListenableScheduledFuture
Helper interface to implement both
ListenableFuture and ScheduledFuture . |
ListenerCallQueue
A list of listeners for implementing a concurrency friendly observable object.
|
ListenerCallQueue.Event
Method reference-compatible listener event.
|
ListenerCallQueue.PerListenerQueue
A special purpose queue/executor that dispatches listener events serially on a configured
executor.
|
ListeningExecutorService
An
ExecutorService that returns ListenableFuture instances. |
ListeningScheduledExecutorService
A
ScheduledExecutorService that returns ListenableFuture instances from its
ExecutorService methods. |
Monitor
A synchronization abstraction supporting waiting on arbitrary boolean conditions.
|
Monitor.Guard
A boolean condition for which a thread may wait.
|
MoreExecutors.DirectExecutor
See
MoreExecutors.directExecutor() for behavioral notes. |
MoreExecutors.ListeningDecorator |
Partially.GwtIncompatible
The presence of this annotation on an API indicates that the method may be used with the
Google Web Toolkit (GWT) but that it has some
restrictions.
|
RateLimiter
A rate limiter.
|
RateLimiter.SleepingStopwatch |
SequentialExecutor.QueueWorker
Worker that runs tasks from
SequentialExecutor.queue until it is empty. |
SequentialExecutor.WorkerRunningState |
Service
An object with an operational state, plus asynchronous
Service.startAsync() and Service.stopAsync() lifecycle methods to transition between states. |
Service.Listener
A listener for the various state changes that a
Service goes through in its lifecycle. |
Service.State
The lifecycle states of a service.
|
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.
|
ServiceManager.ServiceManagerState
An encapsulation of all the mutable state of the
ServiceManager that needs to be
accessed by instances of ServiceManager.ServiceListener . |
SettableFuture
A
ListenableFuture whose result can be set by a SettableFuture.set(Object) , SettableFuture.setException(Throwable) or SettableFuture.setFuture(ListenableFuture) call. |
SimpleTimeLimiter
A TimeLimiter that runs method calls in the background using an
ExecutorService . |
SmoothRateLimiter |
Striped
A striped
Lock/Semaphore/ReadWriteLock . |
Striped.PowerOfTwoStriped |
Striped.SmallLazyStriped.ArrayReference |
Striped.WeakSafeReadWriteLock
ReadWriteLock implementation whose read and write locks retain a reference back to this lock.
|
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
|
TimeLimiter
Imposes a time limit on method calls.
|
TimeoutFuture
Implementation of
Futures#withTimeout . |
TrustedListenableFutureTask
A
RunnableFuture that also implements the ListenableFuture interface. |
WrappingExecutorService
An abstract
ExecutorService that allows subclasses to wrap tasks before they are submitted to the underlying executor. |
Class and Description |
---|
AbstractFuture
An abstract implementation of
ListenableFuture , intended for advanced users only. |
AbstractListeningExecutorService
Abstract
ListeningExecutorService implementation that creates ListenableFuture
instances for each Runnable and Callable submitted to it. |
CheckedFuture
Deprecated.
CheckedFuture cannot properly support the chained operations that are the
primary goal of ListenableFuture . CheckedFuture also encourages users to
rethrow exceptions from one thread in another thread, producing misleading stack traces.
Additionally, it has a surprising policy about which exceptions to map and which to leave
untouched. Guava users who want a CheckedFuture can fork the classes for their own
use, possibly specializing them to the particular exception type they use. We recommend that
most people use ListenableFuture and perform any exception wrapping themselves. This
class is scheduled for removal from Guava in February 2018. |
FluentFuture
A
ListenableFuture that supports fluent chains of operations. |
ForwardingFuture
A
Future which forwards all its method calls to another future. |
ForwardingListenableFuture
A
ListenableFuture which forwards all its method calls to another future. |
ForwardingListenableFuture.SimpleForwardingListenableFuture
A simplified version of
ForwardingListenableFuture where subclasses can pass in an
already constructed ListenableFuture as the delegate. |
GwtFluentFutureCatchingSpecialization
Hidden superclass of
FluentFuture that provides us a place to declare special GWT
versions of the FluentFuture.catching family of methods. |
ListenableFuture
A
Future that accepts completion listeners. |
ListenableScheduledFuture
Helper interface to implement both
ListenableFuture and ScheduledFuture . |
ListeningExecutorService
An
ExecutorService that returns ListenableFuture instances. |
ListeningScheduledExecutorService
A
ScheduledExecutorService that returns ListenableFuture instances from its
ExecutorService methods. |