org.apache.catalina.tribes.transport

Class RxTaskPool

public class RxTaskPool extends Object

Version: 1.0

Author: not attributable

Nested Class Summary
static interfaceRxTaskPool.TaskCreator
Constructor Summary
RxTaskPool(int maxTasks, int minTasks, RxTaskPool.TaskCreator creator)
Method Summary
intavailable()
protected voidconfigureTask(AbstractRxTask task)
intgetMaxThreads()
intgetMinThreads()
AbstractRxTaskgetRxTask()
Find an idle worker thread, if any.
RxTaskPool.TaskCreatorgetTaskCreator()
voidreturnWorker(AbstractRxTask worker)
Called by the worker thread to return itself to the idle pool.
voidsetMaxTasks(int maxThreads)
voidsetMinTasks(int minThreads)
voidstop()

Constructor Detail

RxTaskPool

public RxTaskPool(int maxTasks, int minTasks, RxTaskPool.TaskCreator creator)

Method Detail

available

public int available()

configureTask

protected void configureTask(AbstractRxTask task)

getMaxThreads

public int getMaxThreads()

getMinThreads

public int getMinThreads()

getRxTask

public AbstractRxTask getRxTask()
Find an idle worker thread, if any. Could return null.

getTaskCreator

public RxTaskPool.TaskCreator getTaskCreator()

returnWorker

public void returnWorker(AbstractRxTask worker)
Called by the worker thread to return itself to the idle pool.

setMaxTasks

public void setMaxTasks(int maxThreads)

setMinTasks

public void setMinTasks(int minThreads)

stop

public void stop()
Copyright © 2000-2011 Apache Software Foundation. All Rights Reserved.