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

Class ProcessQueueImpl

java.lang.Object

edu.kit.ipd.sdq.pcm.simulation.scheduler.exact.queueing.basicqueues.ProcessQueueImpl

All Implemented Interfaces:

IProcessQueue

public class ProcessQueueImpl
extends Object
implements IProcessQueue

Constructor Summary

Constructors

Constructor	Description
ProcessQueueImpl(de.uka.ipd.sdq.scheduler.SchedulerModel model)

Method Summary

Modifier and Type	Method	Description
void	add(IActiveProcess process, boolean inFront)
void	addFirst(IActiveProcess process)
void	addLast(IActiveProcess process)
Iterable<IActiveProcess>	ascending()
boolean	contains(IActiveProcess process)
IProcessQueue	createNewInstance()
Iterable<IActiveProcess>	descending()
IProcessQueue	getBestRunnableQueue(IResourceInstance instance)
IActiveProcess	getNextRunnableProcess()
IActiveProcess	getNextRunnableProcess(IResourceInstance instance)
List<IActiveProcess>	getStarvingProcesses(double starvationLimit)
double	getWaitingTime(IActiveProcess process)
void	identifyMovableProcesses(IResourceInstance targetInstance, boolean prio_increasing, boolean queue_ascending, int processes_needed, List<IActiveProcess> process_list)
boolean	isEmpty()
IActiveProcess	peek()
IActiveProcess	poll()
boolean	processStarving(double threshold)
boolean	remove(IActiveProcess process)
void	setWaitingTime(IActiveProcess process, double waiting)
int	size()

Methods inherited from class java.lang.Object

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

Constructor Detail

ProcessQueueImpl

public ProcessQueueImpl(de.uka.ipd.sdq.scheduler.SchedulerModel model)

Method Detail

addLast

public void addLast(IActiveProcess process)

Specified by:

addLast in interface IProcessQueue

addFirst

public void addFirst(IActiveProcess process)

Specified by:

addFirst in interface IProcessQueue

add

public void add(IActiveProcess process,
                boolean inFront)

Specified by:

add in interface IProcessQueue

peek

public IActiveProcess peek()

poll

public IActiveProcess poll()

size

public int size()

Specified by:

size in interface IProcessQueue

remove

public boolean remove(IActiveProcess process)

Specified by:

remove in interface IProcessQueue

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface IProcessQueue

ascending

public Iterable<IActiveProcess> ascending()

Specified by:

ascending in interface IProcessQueue

descending

public Iterable<IActiveProcess> descending()

Specified by:

descending in interface IProcessQueue

contains

public boolean contains(IActiveProcess process)

Specified by:

contains in interface IProcessQueue

getBestRunnableQueue

public IProcessQueue getBestRunnableQueue(IResourceInstance instance)

Specified by:

getBestRunnableQueue in interface IProcessQueue

getNextRunnableProcess

public IActiveProcess getNextRunnableProcess(IResourceInstance instance)

Specified by:

getNextRunnableProcess in interface IProcessQueue

getNextRunnableProcess

public IActiveProcess getNextRunnableProcess()

Specified by:

getNextRunnableProcess in interface IProcessQueue

identifyMovableProcesses

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

Specified by:

identifyMovableProcesses in interface IProcessQueue

createNewInstance

public IProcessQueue createNewInstance()

Specified by:

createNewInstance in interface IProcessQueue

processStarving

public boolean processStarving(double threshold)

Specified by:

processStarving in interface IProcessQueue

setWaitingTime

public void setWaitingTime(IActiveProcess process,
                           double waiting)

Specified by:

setWaitingTime in interface IProcessQueue

getWaitingTime

public double getWaitingTime(IActiveProcess process)

Specified by:

getWaitingTime in interface IProcessQueue

getStarvingProcesses

public List<IActiveProcess> getStarvingProcesses(double starvationLimit)

Specified by:

getStarvingProcesses in interface IProcessQueue