org.jboss.aspects.asynchronous
Interface ThreadManager

All Known Implementing Classes:

ThreadManagerImpl

public interface ThreadManager

Version:

$Revision: 1.2.4.3 $

Author:

{Claude Hussenet Independent Consultant}.

Method Summary

long	getKeepAliveTime() Return the number of milliseconds to keep threads alive waiting for new commands.
int	getMaximumPoolSize() Return the maximum number of threads to use.
int	getMinimumPoolSize() Return the maximum number of threads to simultaneously execute
long	getPoolSize() Return the current number of active threads in the pool.
boolean	getWaitWhenPoolSizeIsFull() return the policy when the pool is full
boolean	isPooling()
AsynchronousTask	process(ThreadManagerRequest ppmRequest) Create, start and return a new asynchronous task from
void	setKeepAliveTime(long time) Set the number of milliseconds to keep threads alive waiting for new commands.
void	setMaximumPoolSize(int maximumPoolSize) Set the maximum number of threads to use.
void	setMinimumPoolSize(int minimumPoolSize) Set the minimum number of threads to use.
void	setPooling(boolean isPooling)
void	setWaitWhenPoolSizeIsFull(boolean value) Set the policy for blocked execution to be to wait until a thread is available.
ThreadManagerResponse	waitForResponse(AsynchronousTask input) Return the response from an asynchronous task The call returns within the timeout defined in the process method
ThreadManagerResponse[]	waitForResponses(AsynchronousTask[] input) Return an array of responses from an array of asynchronous task The call returns within the maximum timeout from the array of tasks

Method Detail

setWaitWhenPoolSizeIsFull

void setWaitWhenPoolSizeIsFull(boolean value)

Set the policy for blocked execution to be to wait until a thread

is available.

OR

Set the policy for blocked execution to be to

throw a RuntimeException.

getWaitWhenPoolSizeIsFull

boolean getWaitWhenPoolSizeIsFull()

return the policy when the pool is full

setMaximumPoolSize

void setMaximumPoolSize(int maximumPoolSize)

Set the maximum number of threads to use.

getMaximumPoolSize

int getMaximumPoolSize()

Return the maximum number of threads to use.

setMinimumPoolSize

void setMinimumPoolSize(int minimumPoolSize)

Set the minimum number of threads to use.

getMinimumPoolSize

int getMinimumPoolSize()

Return the maximum number of threads to simultaneously execute

setKeepAliveTime

void setKeepAliveTime(long time)

Set the number of milliseconds to keep threads alive waiting for

new commands. A negative value means to wait forever. A zero

value means not to wait at all.

getKeepAliveTime

long getKeepAliveTime()

Return the number of milliseconds to keep threads alive waiting

for new commands. A negative value means to wait forever. A zero

value means not to wait at all.

getPoolSize

long getPoolSize()

Return the current number of active threads in the pool.

waitForResponse

ThreadManagerResponse waitForResponse(AsynchronousTask input)

Return the response from an asynchronous task

The call returns within the timeout defined

in the process method

waitForResponses

ThreadManagerResponse[] waitForResponses(AsynchronousTask[] input)

Return an array of responses from an array of asynchronous task

The call returns within the maximum timeout from the array of tasks

process

AsynchronousTask process(ThreadManagerRequest ppmRequest)

Create, start and return a new asynchronous task from

ppmRequest class instance defining the task parameters.

isPooling

boolean isPooling()

setPooling

void setPooling(boolean isPooling)