Package org.threadly.concurrent.wrapper.limiter
Package which limits thread pools and provides the ability to create sub pools from existing
thread pools.
-
Interface Summary Interface Description RejectedExecutionHandler Interface to be invoked when a limiter can not accept a task for any reason. -
Class Summary Class Description ExecutorLimiter This class is designed to limit how much parallel execution happens on a providedExecutor.ExecutorQueueLimitRejector A simple way to limit anyExecutorso that queues are managed.KeyedExecutorLimiter This is a cross between theKeyDistributedExecutorand anExecutorLimiter.KeyedRateLimiterExecutor Similar toRateLimiterExecutorexcept that the rate is applied on a per key basis.KeyedSchedulerServiceLimiter This is a cross between theKeyDistributedSchedulerand aSchedulerServiceLimiter.KeyedSubmitterSchedulerLimiter This is a cross between theKeyDistributedSchedulerand aSubmitterSchedulerLimiter.OrderedExecutorLimiter<T extends java.lang.Runnable> Implementation ofExecutorLimiterwhich allows you to order the tasks in a way other than FIFO.PrioritySchedulerServiceQueueLimitRejector A simple way to limit anyPrioritySchedulerServiceso that queues are managed.RateLimiterExecutor Another way to limit executions on a scheduler.SchedulerServiceLimiter This class is designed to limit how much parallel execution happens on a providedSchedulerService.SchedulerServiceQueueLimitRejector A simple way to limit anySchedulerServiceso that queues are managed.SingleThreadSchedulerSubPool This sub-pool is a special type of limiter.SubmitterSchedulerLimiter This class is designed to limit how much parallel execution happens on a providedSubmitterScheduler.SubmitterSchedulerQueueLimitRejector A simple way to limit anySubmitterSchedulerso that queues are managed.