NewAtomicBool initializes a new AtomicBool with a given value.

NewAtomicDuration initializes a new AtomicDuration with a given value.

NewAtomicInt32 initializes a new AtomicInt32 with a given value.

NewAtomicInt64 initializes a new AtomicInt64 with a given value.

NewBatcher returns a new Batcher.

NewConsolidator creates a new Consolidator.

NewConsolidatorCache creates a new cache with the given capacity.

NewSemaphore creates a Semaphore.

AtomicBool gives an atomic boolean variable.

AtomicDuration is a wrapper with a simpler interface around atomic.(Add|Store|Load|CompareAndSwap)Int64 functions.

AtomicInt32 is a wrapper with a simpler interface around atomic.(Add|Store|Load|CompareAndSwap)Int32 functions.

AtomicInt64 is a wrapper with a simpler interface around atomic.(Add|Store|Load|CompareAndSwap)Int64 functions.

AtomicString gives you atomic-style APIs for string, but it's only a convenience wrapper that uses a mutex.

Batcher delays concurrent operations for a configurable interval in order to batch them up or otherwise clock their operation to run concurrently.

Consolidator consolidates duplicate queries from executing simulaneously and shares results between them.

ConsolidatorCache is a thread-safe object used for counting how often recent queries have been consolidated.

ConsolidatorCacheItem is a wrapper for the items in the consolidator cache.

Result is a wrapper for result of a query.

Semaphore is a counting semaphore with the option to specify a timeout.