Uses of Package
com.google.common.util.concurrent
Packages that use com.google.common.util.concurrent
Package
Description
This package contains caching utilities.
Concurrency utilities.
-
Classes in com.google.common.util.concurrent used by com.google.common.cacheClassDescriptionA
Futurethat accepts completion listeners.AListenableFuturewhose result can be set by aSettableFuture.set(Object),SettableFuture.setException(Throwable)orSettableFuture.setFuture(ListenableFuture)call. -
Classes in com.google.common.util.concurrent used by com.google.common.util.concurrentClassDescriptionImplementations of
Futures.catching*.An abstract implementation ofListenableFuture, intended for advanced users only.A special value to represent cancellation and the 'wasInterrupted' bit.A special value to represent failure, whenAbstractFuture.setException(java.lang.Throwable)is called successfully.Listeners also form a stack through theAbstractFuture.listenersfield.Tag interface marking trusted subclasses.A less abstract subclass of AbstractFuture.Waiter links form a Treiber stack, in theAbstractFuture.waitersfield.AbstractListeningExecutorServiceimplementation that createsListenableFutureinstances for eachRunnableandCallablesubmitted to it.A value object that represents an absolute delay until a task should be invoked.Contains the most recently submittedFuture, which may be cancelled or updated, always under a lock.A scheduler defines the policy for how theAbstractScheduledServiceshould run its task.Base class for implementing services that can handleAbstractService.doStart()andAbstractService.doStop()requests, responding to them withAbstractService.notifyStarted()andAbstractService.notifyStopped()callbacks.An immutable snapshot of the current state of the service.Implementations ofFutures.transform*.A future whose value is derived from a collection of input futures.A helper which does some thread-safe operations for aggregate futures, which must be implemented differently in GWT.Computes a value, possibly asynchronously.Transforms a value, possibly asynchronously.Adoublevalue that may be updated atomically.A map containinglongvalues that can be atomically updated.A step in a pipeline of an asynchronous computation.An operation that computes aClosingFutureof a result.A function from an input to aClosingFutureof a result.An operation that computes a result.A function from an input to a result.A builder of aClosingFuturestep that is derived from more than one input step.An operation that returns aClosingFutureresult and may throw an exception.An operation that returns a result and may throw an exception.A genericClosingFuture.Combinerthat lets you use a lambda or method reference to combine twoClosingFutures.A function that returns aClosingFuturewhen applied to the values of the two futures passed toClosingFuture.whenAllSucceed(ClosingFuture, ClosingFuture).A function that returns a value when applied to the values of the two futures passed toClosingFuture.whenAllSucceed(ClosingFuture, ClosingFuture).A genericClosingFuture.Combinerthat lets you use a lambda or method reference to combine threeClosingFutures.A function that returns aClosingFuturewhen applied to the values of the three futures passed toClosingFuture.whenAllSucceed(ClosingFuture, ClosingFuture, ClosingFuture).A function that returns a value when applied to the values of the three futures passed toClosingFuture.whenAllSucceed(ClosingFuture, ClosingFuture, ClosingFuture).A genericClosingFuture.Combinerthat lets you use a lambda or method reference to combine fourClosingFutures.A function that returns aClosingFuturewhen applied to the values of the four futures passed toClosingFuture.whenAllSucceed(ClosingFuture, ClosingFuture, ClosingFuture, ClosingFuture).A function that returns a value when applied to the values of the four futures passed toClosingFuture.whenAllSucceed(ClosingFuture, ClosingFuture, ClosingFuture, ClosingFuture).A genericClosingFuture.Combinerthat lets you use a lambda or method reference to combine fiveClosingFutures.A function that returns aClosingFuturewhen applied to the values of the five futures passed toClosingFuture.whenAllSucceed(ClosingFuture, ClosingFuture, ClosingFuture, ClosingFuture, ClosingFuture).A function that returns a value when applied to the values of the five futures passed toClosingFuture.whenAllSucceed(ClosingFuture, ClosingFuture, ClosingFuture, ClosingFuture, ClosingFuture).An object that can capture objects to be closed later, when aClosingFuturepipeline is done.An object that can return the value of theClosingFutures that are passed toClosingFuture.whenAllComplete(Iterable)orClosingFuture.whenAllSucceed(Iterable).The state of aClosingFuture.CloseableList.An object that holds the final result of an asynchronousClosingFutureoperation and allows the user to close all the closeable objects that were captured during it for later closing.Represents an operation that accepts aClosingFuture.ValueAndCloserfor the last step in aClosingFuturepipeline.Aggregate future that collects (stores) results of each future.The result of a successfulFuture.TheCycleDetectingLockFactorycreatesReentrantLockinstances andReentrantReadWriteLockinstances that detect potential deadlock by checking for cycles in lock acquisition order.Internal Lock implementations implement theCycleDetectingLockinterface, allowing the detection logic to treat all locks in the same manner.A Throwable used to record a stack trace that illustrates an example of a specific lock acquisition ordering.ALockGraphNodeassociated with each lock instance keeps track of the directed edges in the lock acquisition graph.Pre-definedCycleDetectingLockFactory.Policyimplementations.Encapsulates the action to be taken when a potential deadlock is encountered.Represents a detected cycle in lock acquisition ordering.ACycleDetectingLockFactory.WithExplicitOrderingprovides the additional enforcement of an application-specified ordering of lock acquisitions.Marks all "top-level" types as non-null in a way that is recognized by Kotlin.A support class forListenableFutureimplementations to manage their listeners.Serializes execution of tasks, somewhat like an "asynchronoussynchronizedblock." 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 theFutureit returned is done (successful, failed, or cancelled).This object is unsafely published, but avoids problematic races by relying exclusively on the identity equality of its Thread field so that the task field is only accessed by a single thread.AListenableFuturethat supports fluent chains of operations.A less abstract subclass of AbstractFuture.Forwarding wrapper around aCondition.An executor service which forwards all its method calls to another executor service.AFuturewhich forwards all its method calls to another future.AListenableFuturewhich forwards all its method calls to another future.A simplified version ofForwardingListenableFuturewhere subclasses can pass in an already constructedListenableFutureas the delegate.Forwarding wrapper around aLock.A callback for accepting the results of aFuturecomputation asynchronously.A helper to create a newListenableFuturewhose result is generated from a combination of input futures.Hidden superclass ofFluentFuturethat provides us a place to declare special GWT versions of theFluentFuture.catchingfamily of methods.Hidden superclass ofFuturesthat provides us a place to declare special GWT versions of theFutures.catchingfamily of methods.AFuturethat accepts completion listeners.AFutureTaskthat also implements theListenableFutureinterface.Helper interface to implement bothListenableFutureandScheduledFuture.A list of listeners for implementing a concurrency friendly observable object.Method reference-compatible listener event.A special purpose queue/executor that dispatches listener events serially on a configured executor.AnExecutorServicethat returnsListenableFutureinstances.AScheduledExecutorServicethat returnsListenableFutureinstances from itsExecutorServicemethods.A synchronization abstraction supporting waiting on arbitrary boolean conditions.A boolean condition for which a thread may wait.Marks a "top-level" type-variable usage as (a) a Kotlin platform type when the type argument is non-nullable and (b) nullable when the type argument is nullable.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.A rate limiter.Worker that runs tasks fromSequentialExecutor.queueuntil it is empty.An object with an operational state, plus asynchronousService.startAsync()andService.stopAsync()lifecycle methods to transition between states.A listener for the various state changes that aServicegoes through in its lifecycle.The lifecycle states of a service.A manager for monitoring and controlling a set of services.A listener for the aggregate state changes of the services that are under management.An encapsulation of all the mutable state of theServiceManagerthat needs to be accessed by instances ofServiceManager.ServiceListener.Superinterface ofServiceManagerto introduce a bridge method forservicesByState(), to ensure binary compatibility with older Guava versions that specifiedservicesByState()to returnImmutableMultimap.AListenableFuturewhose result can be set by aSettableFuture.set(Object),SettableFuture.setException(Throwable)orSettableFuture.setFuture(ListenableFuture)call.A TimeLimiter that runs method calls in the background using anExecutorService.A stripedLock/Semaphore/ReadWriteLock.ReadWriteLock implementation whose read and write locks retain a reference back to this lock.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 factoryImposes a time limit on method calls.Implementation ofFutures#withTimeout.ARunnableFuturethat also implements theListenableFutureinterface.An abstractExecutorServicethat allows subclasses to wrap tasks before they are submitted to the underlying executor. -
Classes in com.google.common.util.concurrent used by com.google.common.util.concurrent.testingClassDescriptionAn abstract implementation of
ListenableFuture, intended for advanced users only.AbstractListeningExecutorServiceimplementation that createsListenableFutureinstances for eachRunnableandCallablesubmitted to it.AFuturewhich forwards all its method calls to another future.AListenableFuturewhich forwards all its method calls to another future.A simplified version ofForwardingListenableFuturewhere subclasses can pass in an already constructedListenableFutureas the delegate.AFuturethat accepts completion listeners.Helper interface to implement bothListenableFutureandScheduledFuture.AnExecutorServicethat returnsListenableFutureinstances.AScheduledExecutorServicethat returnsListenableFutureinstances from itsExecutorServicemethods.