Package com.facebook.buck.util.concurrent

Interface Summary

Interface	Description
AssertScopeExclusiveAccess.Scope
CommonThreadFactoryState
Parallelizer	Interface to transform high level constructs to potentially parallel ones.
ResourcePool.ThrowingFunction<T,R>
ThreadIdToCommandIdMapper

Class Summary

Class	Description
AssertScopeExclusiveAccess	Makes it simple to assert that access to a piece of code should be done from one thread at a time in a non-reentrant manner.
AutoCloseableLock
AutoCloseableReadWriteLock	Convenience wrapper around ReentrantReadWriteLock that, when combined with try-with-resources pattern, automatically unlocks the lock once the try section is completed.
AutoCloseableReadWriteUpdateLock
CommandThreadFactory	A ThreadFactory which associates created threads with the same command associated with the thread which creates the CommandThreadFactory.
ConcurrencyLimit	Amalgamation of parameters that control how many jobs we can run at once.
JobLimiter	JobLimiter is a simple mechanism for queuing asynchronous work such that only a certain number of items are active at a time.
LinkedBlockingStack<E>	An implementation of BlockingQueue interface returning elements in LIFO order.
ListeningMultiSemaphore	A semaphore using ListenableFutures for acquisition of different resource types rather than blocking.
MoreAtomics	Utility methods for common routines with atomic variables
MoreFutures
MostExecutors
MostExecutors.NamedThreadFactory	A ThreadFactory which gives each thread a meaningful and distinct name.
ResourceAmounts
ResourceAmountsEstimator
ResourcePool<R extends AutoCloseable>	Allows multiple concurrently executing futures to share a constrained number of resources.
WeightedListeningExecutorService	A ListeningExecutorService which gates execution using a ListeningMultiSemaphore and allows resources to be assigned to submitted tasks.
WorkThreadTrackingTask<T>	A ForkJoinTask which keeps track of the thread running its computation.

Enum Summary

Enum	Description
ExecutorPool
ResourceAllocationFairness	How to handle fairness when acquiring the semaphore.
ResourcePool.ResourceUsageErrorPolicy	Describes how to handle errors that take place during resource usage.