Package com.linkedin.alpini.base.concurrency
package com.linkedin.alpini.base.concurrency
-
ClassDescriptionA thread-safe
SortedSetimplementation which uses an array as a backing store.AsyncFuture<T>AFuturewhich has very netty-style semantics whereAsyncFutureListenercan be added to the future to be executed upon condition of Success or Failure has been satisfied.An interface (lambda) which is fired upon completion of anAsyncFuture.AsyncPromise<T>A completableAsyncFutureinterface.Created by acurtis on 10/16/17.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.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.Factory and utility methods forExecutor,ExecutorService,ScheduledExecutorService,ThreadFactory, andCallableclasses defined in this package.An analog toExecutorServiceexcept that the futures returned areAsyncFutures.Lazy<T>Created by acurtis on 3/29/17.ThreadFactory which creates named threads for use in an ExecutorService.A simple filterRunnablewhich will only invoke the contained runnable no more than once.An analog toScheduledExecutorServicewhich extendsExecutorService.ThreadedAccumulator<T,A, R> More efficient handling of cancellable schedulable events.