Package com.linkedin.alpini.base.concurrency

Interface Summary

Interface	Description
AsyncFuture<T>	A Future which has very netty-style semantics where AsyncFutureListener can be added to the future to be executed upon condition of Success or Failure has been satisfied.
AsyncFutureListener<T>	An interface (lambda) which is fired upon completion of an AsyncFuture.
AsyncPromise<T>	A completable AsyncFuture interface.
ExecutorService	An analog to ExecutorService except that the futures returned are AsyncFutures.
ScheduledExecutorService	An analog to ScheduledExecutorService which extends ExecutorService.

Class Summary

Class	Description
ArraySortedSet<E>	A thread-safe SortedSet implementation which uses an array as a backing store.
BlockingLatch	Created by acurtis on 10/16/17.
CompletableFutureTask<V>	Created by acurtis on 4/4/17.
ComplexAccumulator<T,A,R>	One or more variables that together maintain an accumulation.
ConcurrentAccumulator<T,A,R>	One or more variables that together maintain an accumulation.
ConcurrentLinkedBlockingQueue<E>	A BlockingQueue implementation which uses a collection of concurrent Queues per thread in order to reduce the hotspot of a highly contended mutex or atomic reference.
Lazy<T>	Created by acurtis on 3/29/17.
NamedThreadFactory	ThreadFactory which creates named threads for use in an ExecutorService.
RunOnce	A simple filter Runnable which will only invoke the contained runnable no more than once.
StripedAccumulator<A>
ThreadedAccumulator<T,A,R>
TimeoutProcessor	More efficient handling of cancellable schedulable events.
TimeoutProcessor.TimeoutFuture

Enum Summary

Enum	Description
AsyncFuture.Status
ConcurrentAccumulator.Mode
Executors	Factory and utility methods for Executor, ExecutorService, ScheduledExecutorService, ThreadFactory, and Callable classes defined in this package.