Package | Description |
---|---|
org.aredis.util.concurrent |
Contains utilities related to concurrent programming (java.util.concurrent package).
|
Class and Description |
---|
EmptyRunnable
A Singleton implementing Runnable whose run method does nothing.
|
LimitingTaskExecutor
This class is a utility class implementing ExecutorService which can sit on top of any ExecutorService
like ThreadPoolExecutor and limit the number of concurrent tasks submitted to it using a configured limit.
|
RejectedTaskHandler
Interface specifying the action to be taken when a task is rejected by a
LimitingTaskExecutor . |
SimpleThreadFactory
A utility class which cannot be instantiated but which provides two final instances of ThreadFactorys one for
creating daemon threads and one for creating user threads.
|
SingleConsumerQueue
This is a Wrapper over a
LinkedBlockingQueue for use with a Single Consumer. |
SingleConsumerQueue.IdleListener
Callback Interface to get called back when the IDLE status of the Q changes.
|
SingleConsumerQueue.QueueStatus |
Copyright © 2013- Suresh Mahalingam. All Rights Reserved.