Package edu.kit.ipd.sdq.pcm.simulation.scheduler.exact.queueing.runqueues

Class ActiveExpiredRunQueue

java.lang.Object

edu.kit.ipd.sdq.pcm.simulation.scheduler.exact.queueing.runqueues.AbstractRunQueue

edu.kit.ipd.sdq.pcm.simulation.scheduler.exact.queueing.runqueues.ActiveExpiredRunQueue

All Implemented Interfaces:

IRunQueue

public class ActiveExpiredRunQueue
extends AbstractRunQueue

Field Summary

Fields inherited from class edu.kit.ipd.sdq.pcm.simulation.scheduler.exact.queueing.runqueues.AbstractRunQueue

running_on_table

Constructor Summary

Constructors

Constructor	Description
ActiveExpiredRunQueue(de.uka.ipd.sdq.scheduler.SchedulerModel model, IProcessQueue queue_prototype)

Method Summary

Modifier and Type	Method	Description
protected boolean	activeQueueEmpty()	Determines whether the current active queue is empty including the running and standby processes.
void	addProcessToRunQueue(IActiveProcess process, boolean inFront)	Adds a new process to the end of the expired priority array.
boolean	containsPending(IActiveProcess process)	Template Method.
IRunQueue	createNewInstance()	Prototype Object Pattern.
IProcessQueue	getBestRunnableQueue(IResourceInstance instance)
IActiveProcess	getNextRunnableProcess()	Returns the next runnable process.
IActiveProcess	getNextRunnableProcess(IResourceInstance instance)	Returns the next process runnable on the given instance.
List<IActiveProcess>	getStarvingProcesses(double starvationLimit)
double	getWaitingTime(IActiveProcess process)
List<IActiveProcess>	identifyMovableProcesses(IResourceInstance targetInstance, boolean prio_increasing, boolean queue_ascending, int processes_needed)	Composes a list of processes movable to the specified target.
protected int	numWaitingProcesses()	Template Method.
boolean	processStarving(double threshold)
boolean	removePendingProcess(IActiveProcess process)	Template method.
void	resetStarvationInfo()
void	setWaitingTime(IActiveProcess process, double waiting)

Methods inherited from class edu.kit.ipd.sdq.pcm.simulation.scheduler.exact.queueing.runqueues.AbstractRunQueue

addProcess, contains, containsRunning, getCurrentLoad, isEmpty, isIdle, removeProcess, removeRunning, runningOn, setRunningOn

Methods inherited from class java.lang.Object

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

Constructor Detail

ActiveExpiredRunQueue

public ActiveExpiredRunQueue(de.uka.ipd.sdq.scheduler.SchedulerModel model,
                             IProcessQueue queue_prototype)

Method Detail

addProcessToRunQueue

public void addProcessToRunQueue(IActiveProcess process,
                                 boolean inFront)

Adds a new process to the end of the expired priority array.

Specified by:

addProcessToRunQueue in class AbstractRunQueue

numWaitingProcesses

protected int numWaitingProcesses()

Description copied from class: AbstractRunQueue

Template Method. Returns the number of processs waiting in the queue.

Specified by:

numWaitingProcesses in class AbstractRunQueue

Returns:

getNextRunnableProcess

public IActiveProcess getNextRunnableProcess(IResourceInstance instance)

Description copied from interface: IRunQueue

Returns the next process runnable on the given instance.

Specified by:

getNextRunnableProcess in interface IRunQueue

Specified by:

getNextRunnableProcess in class AbstractRunQueue

getNextRunnableProcess

public IActiveProcess getNextRunnableProcess()

Description copied from interface: IRunQueue

Returns the next runnable process.

Returns:

removePendingProcess

public boolean removePendingProcess(IActiveProcess process)

Description copied from class: AbstractRunQueue

Template method. Removes the given process from the queue.

Specified by:

removePendingProcess in interface IRunQueue

Specified by:

removePendingProcess in class AbstractRunQueue

Parameters:

process - Process of interest.

Returns:

True, if the process was successfully removed, otherwise (if the process was not found) false.

activeQueueEmpty

protected boolean activeQueueEmpty()

Determines whether the current active queue is empty including the running and standby processes.

createNewInstance

public IRunQueue createNewInstance()

Description copied from interface: IRunQueue

Prototype Object Pattern. Creates a new instance of the given runqueue.

Returns:

identifyMovableProcesses

public List<IActiveProcess> identifyMovableProcesses(IResourceInstance targetInstance,
                                                     boolean prio_increasing,
                                                     boolean queue_ascending,
                                                     int processes_needed)

Description copied from interface: IRunQueue

Composes a list of processes movable to the specified target. The list is ordered in terms of what suits best for the target resource instance. The first element is better than the second which is better than the third and so on. Note that currently running processes are never added to the movable list.

Parameters:

targetInstance - Resource instance the processes shall be moved to.

prio_increasing - If true, the processes in the resulting list are ordered with an increasing priority, otherwise with a decreasing priority.

queue_ascending - If true, processes in the resulting list are in the same order as in the queue, otherwise they are in reverse order.

processes_needed - The maximum number of processes needed for the resource.

Returns:

An ordered list of processes movable to the target resource.

getBestRunnableQueue

public IProcessQueue getBestRunnableQueue(IResourceInstance instance)

Parameters:

instance - Resource instance a process is needed for.

Returns:

Returns the most urgent queue which contains at least one process which can run on the given instance. NULL if no such queue exists.

containsPending

public boolean containsPending(IActiveProcess process)

Description copied from class: AbstractRunQueue

Template Method. Returns

Specified by:

containsPending in interface IRunQueue

Specified by:

containsPending in class AbstractRunQueue

Parameters:

process - Process of interest.

Returns:

True, if the process is pending in the runqueue.

processStarving

public boolean processStarving(double threshold)

getStarvingProcesses

public List<IActiveProcess> getStarvingProcesses(double starvationLimit)

setWaitingTime

public void setWaitingTime(IActiveProcess process,
                           double waiting)

getWaitingTime

public double getWaitingTime(IActiveProcess process)

resetStarvationInfo

public void resetStarvationInfo()