Package com.linkedin.alpini.base.concurrency
package com.linkedin.alpini.base.concurrency
-
ClassDescriptionAsyncFuture<T>A
Future
which has very netty-style semantics whereAsyncFutureListener
can 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 completableAsyncFuture
interface.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
, andCallable
classes defined in this package.An analog toExecutorService
except that the futures returned areAsyncFuture
s.Lazy<T>Created by acurtis on 3/29/17.ThreadFactory which creates named threads for use in an ExecutorService.A simple filterRunnable
which will only invoke the contained runnable no more than once.An analog toScheduledExecutorService
which extendsExecutorService
.ThreadedAccumulator<T,A, R> More efficient handling of cancellable schedulable events.