Class Queue

java.lang.Object

QueueNet.NodeSection

NodeSections.PipeSection

NodeSections.InputSection

NodeSections.Queue

public class Queue
extends InputSection

Name: Queue

Description:

Date: 15/nov/2009 Time: 23.08.16

Version:

3.0

Author:

Bertoli Marco [marco.bertoli@neptuny.com]

Field Summary

Fields

Modifier and Type	Field	Description
static final String	FINITE_BLOCK
static final String	FINITE_DROP
static final String	FINITE_RETRIAL
static final String	FINITE_WAITING

Fields inherited from class NodeSection

EXCEPTION_MEASURE_DOES_NOT_EXIST, EXCEPTION_PROPERTY_NOT_AVAILABLE, INPUT, jobsList, logger, MSG_NOT_PROCESSED, MSG_PROCESSED, NO_ADDRESS, OUTPUT, PROPERTY_ID_ARRIVING_JOBS, PROPERTY_ID_AVERAGE_UTILIZATION, PROPERTY_ID_DEPARTING_JOBS, PROPERTY_ID_RESIDENCE_TIME, PROPERTY_ID_RESIDENT_JOBS, PROPERTY_ID_UTILIZATION, SERVICE

Constructor Summary

Constructors

Constructor	Description
Queue(Integer capacity, String[] dropStrategies, QueueGetStrategy getStrategy, QueuePutStrategy[] putStrategies)
Queue(Integer capacity, String[] dropStrategies, QueueGetStrategy getStrategy, QueuePutStrategy[] putStrategies, Impatience[] impatienceStrategies)
Queue(Integer capacity, String[] dropStrategies, QueueGetStrategy getStrategy, QueuePutStrategy[] putStrategies, TransitionMatrix[] enablingConditions, TransitionMatrix[] inhibitingConditions, TransitionMatrix[] resourceConditions)
Queue(Integer capacity, String[] dropStrategies, ServiceStrategy[] retrialDistributions, QueueGetStrategy getStrategy, QueuePutStrategy[] putStrategies)
Queue(Integer capacity, String[] dropStrategies, ServiceStrategy[] retrialDistributions, QueueGetStrategy getStrategy, QueuePutStrategy[] putStrategies, Impatience[] impatienceStrategies, Boolean workingAsTransition, TransitionMatrix[] enablingConditions, TransitionMatrix[] inhibitingConditions, TransitionMatrix[] resourceConditions)	Creates a new instance of finite Queue.

Method Summary

Modifier and Type	Method	Description
void	analyzeFJ(int name, JobClass jobClass, Measure measurement)
int	getStationCapacity()	This method returns the capacity of the station (queue+server).
boolean	isRedirectionON()	Tells whether the "redirecting queue" behaviour has been turned on.
boolean	isStationWorkingAsATransition()
protected void	nodeLinked(NetNode node)	This method should be overridden to implement a specific behaviour of the node section when the node section itself is linked to the owner node.
void	preloadJobs(int[] jobsPerClass)	Preloads the specified numbers of jobs for each class.
protected int	process(NetMessage message)	This method implements a generic finite/infinite queue.
void	redirectionTurnOFF()	Turns off the "redirecting queue" behaviour.
void	redirectionTurnON(BlockingRegion region)	Turns on the "redirecting queue" behaviour.
void	setSoftDeadlines(double[] softDeadlines)

Methods inherited from class InputSection

sendForward, sendForward

Methods inherited from class NodeSection

analyze, analyze, analyzeFCR, analyzeJoin, analyzeTransition, getClassCompatibilities, getDoubleSectionProperty, getDoubleSectionProperty, getIntSectionProperty, getIntSectionProperty, getJobClasses, getJobInfoList, getObject, getObject, getOwnerNode, getParameter, getParameter, getSectionID, getServerTypes, isEnabled, isEnabled, isMine, isMyOwnerNode, redirect, removeMessage, send, send, send, send, send, send, sendAckAfterDrop, sendMe, sendMe, updateVisitPath

Methods inherited from class Object

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

Field Details

FINITE_DROP

public static final String FINITE_DROP

See Also:

• Constant Field Values

FINITE_BLOCK

public static final String FINITE_BLOCK

See Also:

• Constant Field Values

FINITE_WAITING

public static final String FINITE_WAITING

See Also:

• Constant Field Values

FINITE_RETRIAL

public static final String FINITE_RETRIAL

See Also:

• Constant Field Values

Constructor Details

Queue

public Queue(Integer capacity,
 String[] dropStrategies,
 QueueGetStrategy getStrategy,
 QueuePutStrategy[] putStrategies)

Queue

public Queue(Integer capacity,
 String[] dropStrategies,
 ServiceStrategy[] retrialDistributions,
 QueueGetStrategy getStrategy,
 QueuePutStrategy[] putStrategies)

Queue

public Queue(Integer capacity,
 String[] dropStrategies,
 QueueGetStrategy getStrategy,
 QueuePutStrategy[] putStrategies,
 Impatience[] impatienceStrategies)

Queue

public Queue(Integer capacity,
 String[] dropStrategies,
 QueueGetStrategy getStrategy,
 QueuePutStrategy[] putStrategies,
 TransitionMatrix[] enablingConditions,
 TransitionMatrix[] inhibitingConditions,
 TransitionMatrix[] resourceConditions)

Queue

public Queue(Integer capacity,
 String[] dropStrategies,
 ServiceStrategy[] retrialDistributions,
 QueueGetStrategy getStrategy,
 QueuePutStrategy[] putStrategies,
 Impatience[] impatienceStrategies,
 Boolean workingAsTransition,
 TransitionMatrix[] enablingConditions,
 TransitionMatrix[] inhibitingConditions,
 TransitionMatrix[] resourceConditions)

Creates a new instance of finite Queue. This is the newest constructor that supports different drop strategies. Other constructors are left for compatibility.

Parameters:

capacity - Station capacity (-1 = infinite capacity).

dropStrategies - Drop strategy per class: FINITE_DROP || FINITE_BLOCK || FINITE_WAITING || FINITE_RETRIAL.

retrialDistributions - Retrial distribution per class.

getStrategy - Queue get strategy.

putStrategies - Queue put strategy per class.

impatienceStrategies - Impatience strategy per class.

Method Details

isRedirectionON

public boolean isRedirectionON()

Tells whether the "redirecting queue" behaviour has been turned on.

Returns:

true, if the "redirecting queue" behaviour is on; false otherwise.

redirectionTurnON

public void redirectionTurnON(BlockingRegion region)

Turns on the "redirecting queue" behaviour.

Parameters:

region - the blocking region to which the owner node of this queue belongs.

redirectionTurnOFF

public void redirectionTurnOFF()

Turns off the "redirecting queue" behaviour.

nodeLinked

protected void nodeLinked(NetNode node)
                   throws NetException

Description copied from class: NodeSection

This method should be overridden to implement a specific behaviour of the node section when the node section itself is linked to the owner node. This method should be used to set node section properties depending on the owner node ones.

Overrides:

nodeLinked in class NodeSection

Parameters:

node - Owner node.

Throws:

NetException

preloadJobs

public void preloadJobs(int[] jobsPerClass)
                 throws NetException

Preloads the specified numbers of jobs for each class.

Parameters:

jobsPerClass - the specified numbers of jobs for each class.

Throws:

NetException

process

protected int process(NetMessage message)
               throws NetException

This method implements a generic finite/infinite queue.

Specified by:

process in class NodeSection

Parameters:

message - message to be processed.

Returns:

the resulting int

Throws:

NetException

getStationCapacity

public int getStationCapacity()

This method returns the capacity of the station (queue+server).

analyzeFJ

public void analyzeFJ(int name,
 JobClass jobClass,
 Measure measurement)
               throws NetException

Overrides:

analyzeFJ in class NodeSection

Throws:

NetException

isStationWorkingAsATransition

public boolean isStationWorkingAsATransition()

setSoftDeadlines

public void setSoftDeadlines(double[] softDeadlines)