jadex.commons.concurrent

Class DefaultThreadPoolStrategy

java.lang.Object

jadex.commons.concurrent.DefaultThreadPoolStrategy

All Implemented Interfaces:

IThreadPoolStrategy

public class DefaultThreadPoolStrategy
extends Object
implements IThreadPoolStrategy

This strategy has two parameters: - The desired number of free threads in the pool. - The maximum timeout for threads to wait for new tasks.

Constructor Summary

Constructors

Constructor and Description
DefaultThreadPoolStrategy(int threadcnt, int desfree, long maxwait, int maxthreadcnt) Create a new default threadpool strategy.

Method Summary

Methods

Modifier and Type	Method and Description
int	getThreadCount() Get the threadcnt.
long	getThreadTimeout() Get the thread timeout.
boolean	taskAdded() Called when a new task was added to the pool.
boolean	taskFinished() Called when a task is finished.
boolean	threadTimeoutOccurred() Notify the strategy that a timeout for a thread has occurred, i.e. it was not needed for serving some task.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultThreadPoolStrategy

public DefaultThreadPoolStrategy(int threadcnt,
                         int desfree,
                         long maxwait,
                         int maxthreadcnt)

Create a new default threadpool strategy.

Method Detail

taskAdded

public boolean taskAdded()

Called when a new task was added to the pool.

Specified by:

taskAdded in interface IThreadPoolStrategy

Returns:

True, if a new thread should be added to the pool.

taskFinished

public boolean taskFinished()

Called when a task is finished.

Specified by:

taskFinished in interface IThreadPoolStrategy

Returns:

True, if executing thread be excluded from the pool.

getThreadTimeout

public long getThreadTimeout()

Get the thread timeout.

Specified by:

getThreadTimeout in interface IThreadPoolStrategy

Returns:

The timeout for the thread to wait for new tasks in the pool.

threadTimeoutOccurred

public boolean threadTimeoutOccurred()

Notify the strategy that a timeout for a thread has occurred, i.e. it was not needed for serving some task.

Specified by:

threadTimeoutOccurred in interface IThreadPoolStrategy

Returns:

True, if the thread be excluded from the pool.

getThreadCount

public int getThreadCount()

Get the threadcnt.

Specified by:

getThreadCount in interface IThreadPoolStrategy