jadex.commons

Class DefaultPoolStrategy

java.lang.Object

jadex.commons.DefaultPoolStrategy

All Implemented Interfaces:

IPoolStrategy

public class DefaultPoolStrategy
extends Object
implements IPoolStrategy

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

Constructor Summary

Constructors

Constructor and Description
DefaultPoolStrategy() Create a new default pool strategy.
DefaultPoolStrategy(int desfree, int maxcnt) Create a new default pool strategy.
DefaultPoolStrategy(int workercnt, int desfree, long maxwait, int maxcnt) Create a new default pool strategy.
DefaultPoolStrategy(int workercnt, int desfree, long maxwait, int maxcnt, boolean defer) Create a new default pool strategy.
DefaultPoolStrategy(int workercnt, int desfree, long maxwait, int maxcnt, boolean deferinc, boolean deferdec) Create a new default pool strategy.
DefaultPoolStrategy(int desfree, long maxwait, int maxcnt) Create a new default pool strategy.

Method Summary

Methods

Modifier and Type	Method and Description
int	getCapacity() Get the capacity.
int	getDesiredFree() Get the desfree.
int	getMaxCount() Get the max cnt.
long	getMaxWait() Get the maxwait.
int	getWorkerCount() Get the worker cnt.
long	getWorkerTimeout() Get the worker timeout.
void	setCapacity(int capacity) Set the capacity.
void	setDesiredFree(int desfree) Set the desfree.
void	setMaxCount(int maxcnt) Set the max cnt.
void	setMaxWait(long maxwait) Set the maxwait.
void	setWorkerCount(int workercnt) Set the worker cnt.
boolean	taskAdded() Called when a new task was added to the pool.
boolean	taskFinished() Called when a task is finished.
void	taskServed(long waitdur) Called when a new task was served from the pool.
String	toString() Get the string representation.
void	workersAdded(int cnt) Called when a new worker was added proactively to the pool.
boolean	workerTimeoutOccurred() Notify the strategy that a timeout for a worker has occurred, i.e. it was not needed for serving some task.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultPoolStrategy

public DefaultPoolStrategy()

Create a new default pool strategy.

DefaultPoolStrategy

public DefaultPoolStrategy(int desfree,
                   int maxcnt)

Create a new default pool strategy.

DefaultPoolStrategy

public DefaultPoolStrategy(int desfree,
                   long maxwait,
                   int maxcnt)

Create a new default pool strategy.

DefaultPoolStrategy

public DefaultPoolStrategy(int workercnt,
                   int desfree,
                   long maxwait,
                   int maxcnt)

Create a new default pool strategy.

DefaultPoolStrategy

public DefaultPoolStrategy(int workercnt,
                   int desfree,
                   long maxwait,
                   int maxcnt,
                   boolean defer)

Create a new default pool strategy.

DefaultPoolStrategy

public DefaultPoolStrategy(int workercnt,
                   int desfree,
                   long maxwait,
                   int maxcnt,
                   boolean deferinc,
                   boolean deferdec)

Create a new default pool strategy.

Method Detail

taskAdded

public boolean taskAdded()

Called when a new task was added to the pool.

Specified by:

taskAdded in interface IPoolStrategy

Returns:

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

workersAdded

public void workersAdded(int cnt)

Called when a new worker was added proactively to the pool.

Specified by:

workersAdded in interface IPoolStrategy

Parameters:

cnt - The number of new workers.

taskServed

public void taskServed(long waitdur)

Called when a new task was served from the pool.

Specified by:

taskServed in interface IPoolStrategy

Parameters:

waitdur - The waiting time of the task.

taskFinished

public boolean taskFinished()

Called when a task is finished.

Specified by:

taskFinished in interface IPoolStrategy

Returns:

True, if executing worker be excluded from the pool.

getWorkerTimeout

public long getWorkerTimeout()

Get the worker timeout.

Specified by:

getWorkerTimeout in interface IPoolStrategy

Returns:

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

workerTimeoutOccurred

public boolean workerTimeoutOccurred()

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

Specified by:

workerTimeoutOccurred in interface IPoolStrategy

Returns:

True, if the worker be excluded from the pool.

getWorkerCount

public int getWorkerCount()

Get the worker cnt.

Specified by:

getWorkerCount in interface IPoolStrategy

setWorkerCount

public void setWorkerCount(int workercnt)

Set the worker cnt.

Parameters:

workercnt - The workercnt to set.

getCapacity

public int getCapacity()

Get the capacity.

Specified by:

getCapacity in interface IPoolStrategy

Returns:

The capacity.

setCapacity

public void setCapacity(int capacity)

Set the capacity.

Parameters:

capacity - The capacity to set.

getDesiredFree

public int getDesiredFree()

Get the desfree.

Returns:

The desfree.

setDesiredFree

public void setDesiredFree(int desfree)

Set the desfree.

Parameters:

desfree - The desfree to set.

getMaxWait

public long getMaxWait()

Get the maxwait.

Returns:

The maxwait.

setMaxWait

public void setMaxWait(long maxwait)

Set the maxwait.

Parameters:

maxwait - The maxwait to set.

getMaxCount

public int getMaxCount()

Get the max cnt.

Returns:

The max cnt.

setMaxCount

public void setMaxCount(int maxcnt)

Set the max cnt.

Parameters:

maxservicecnt - The max cnt to set.

toString

public String toString()

Get the string representation.

Overrides:

toString in class Object