org.apache.catalina.tribes.transport
Class RxTaskPool
java.lang.Object
org.apache.catalina.tribes.transport.RxTaskPool
public class RxTaskPool
- extends java.lang.Object
- Version:
- 1.0
- Author:
- not attributable
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
RxTaskPool
public RxTaskPool(int maxTasks,
int minTasks,
RxTaskPool.TaskCreator creator)
throws java.lang.Exception
- Throws:
java.lang.Exception
configureTask
protected void configureTask(AbstractRxTask task)
getRxTask
public AbstractRxTask getRxTask()
- Find an idle worker thread, if any. Could return null.
available
public int available()
returnWorker
public void returnWorker(AbstractRxTask worker)
- Called by the worker thread to return itself to the
idle pool.
getMaxThreads
public int getMaxThreads()
getMinThreads
public int getMinThreads()
stop
public void stop()
setMaxTasks
public void setMaxTasks(int maxThreads)
setMinTasks
public void setMinTasks(int minThreads)
getTaskCreator
public RxTaskPool.TaskCreator getTaskCreator()
Copyright © 2000-2017 Apache Software Foundation. All Rights Reserved.