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() |