Package com.linkedin.alpini.base.concurrency
package com.linkedin.alpini.base.concurrency
-
ClassDescriptionAsyncFuture<T>A
Futurewhich 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.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.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.