org.apache.catalina.tribes.transport
public class RxTaskPool extends Object
Version: 1.0
Nested Class Summary | |
---|---|
static interface | RxTaskPool.TaskCreator |
Constructor Summary | |
---|---|
RxTaskPool(int maxTasks, int minTasks, RxTaskPool.TaskCreator creator) |
Method Summary | |
---|---|
int | available() |
protected void | configureTask(AbstractRxTask task) |
int | getMaxThreads() |
int | getMinThreads() |
AbstractRxTask | getRxTask()
Find an idle worker thread, if any. |
RxTaskPool.TaskCreator | getTaskCreator() |
void | returnWorker(AbstractRxTask worker)
Called by the worker thread to return itself to the
idle pool. |
void | setMaxTasks(int maxThreads) |
void | setMinTasks(int minThreads) |
void | stop() |