Package | Description |
---|---|
org.aredis.util.concurrent |
Contains utilities related to concurrent programming (java.util.concurrent package).
|
Modifier and Type | Field and Description |
---|---|
static RejectedTaskHandler |
LimitingTaskExecutor.ABORT_POLICY
RejectedTaskHandler which Aborts the rejected task by throwing a RejectedExecutionException.
|
static RejectedTaskHandler |
LimitingTaskExecutor.DISCARD_POLICY
RejectedTaskHandler which discards the rejected task by doing nothing.
|
static RejectedTaskHandler |
LimitingTaskExecutor.RUN_IN_PLACE_POLICY
RejectedTaskHandler which runs the rejected task in place by calling the run method
of the submitted task so that the task runs in the same thread as the caller effectively
slowing down the caller thread.
|
Constructor and Description |
---|
LimitingTaskExecutor(ExecutorService pexecutorService,
int ptaskLimit,
BlockingQueue<Runnable> pwaitingTasks,
RejectedTaskHandler prejectedTaskHandler)
Creates a Limiting TaskExecutor.
|
Copyright © 2013- Suresh Mahalingam. All Rights Reserved.