proter-root/com.workflowfm.proter.schedule/GreedyPriorityScheduler

GreedyPriorityScheduler

class GreedyPriorityScheduler(initialTasks: TaskInstance*) extends PriorityScheduler with GreedyScheduler

A greedy priority Scheduler.

Starts all tasks whose resources are currently idle, in order of priority.

This means a lower priority task may start now and block a higher priority task which is currently blocked, but could have started soon.

Value Params
initialTasks

Initial TaskInstances in the queue, if any.

trait Scheduler
class Object
trait Matchable
class Any

Value members

Inherited methods

override
def addTask(task: TaskInstance): Unit

Adds a TaskInstance to be scheduled.

Adds a TaskInstance to be scheduled.

Definition Classes
Inherited from
PriorityScheduler
def complete(task: TaskInstance, time: Long): Unit

Adds an Task described by an (ID,time) pair to the list of completed IDs

Adds an Task described by an (ID,time) pair to the list of completed IDs

Value Params
id

The ID to be added

time

The time at which the task completed

Returns

A LookaheadStructure with this (ID,time) pair added to the list of completed tasks

Inherited from
Scheduler
@tailrec
final protected
def findNextTasks(idleResources: Map[String, TaskResource], tasks: Iterable[TaskInstance], result: Queue[TaskInstance]): Seq[TaskInstance]

Finds the Tasks that can be started now.

Finds the Tasks that can be started now.

Goes through the priority list of tasks and returns those whose resources are idle (even after starting higher priority tasks).

Value Params
idleResources

The map of idle TaskResources.

result

The accumulated TaskInstances so far (for tail recursion).

tasks

The set of TaskInstances that need to start.

Returns

The sequence of TaskInstances to start now.

Inherited from
GreedyScheduler
override
def getNextTasks(currentTime: Long, resourceMap: Map[String, TaskResource]): Seq[TaskInstance]
Definition Classes
Inherited from
GreedyScheduler
override
def getTasks(): Iterable[TaskInstance]

Retrieves an iterable collection of queued TaskInstances.

Retrieves an iterable collection of queued TaskInstances.

Definition Classes
Inherited from
PriorityScheduler
def isIdleResource(r: String, resourceMap: Map[String, TaskResource]): Boolean

Checks if a named TaskResource is idle.

Checks if a named TaskResource is idle.

Value Params
r

The name of the TaskResource.

resourceMap

The map of available TaskResources.

Returns

true if the resource is idle, false otherwise.

Inherited from
Scheduler
override
def noMoreTasks(): Boolean

Checks if all Tasks have been scheduled.

Checks if all Tasks have been scheduled.

Definition Classes
Inherited from
PriorityScheduler
def removeLookahead(simulation: String): Unit

Removes the lookahead structure associated with the given actor.

Removes the lookahead structure associated with the given actor.

Value Params
actor

The actor corresponding to the lookahead structure.

Inherited from
Scheduler
override
def removeSimulation(simulation: String): Unit

Removes all TaskInstances belonging to an (presumably aborted) simulation.

Removes all TaskInstances belonging to an (presumably aborted) simulation.

Definition Classes
Inherited from
PriorityScheduler
override
def removeTask(task: TaskInstance): Unit

Removes a TaskInstance that no longer needs scheduling.

Removes a TaskInstance that no longer needs scheduling.

Definition Classes
Inherited from
PriorityScheduler
def setLookahead(simulation: String, obj: Lookahead): Unit

Sets the lookahead structure for the specified actor.

Sets the lookahead structure for the specified actor.

Value Params
actor

The actor that created this lookahead structure.

obj

The lookahead structure.

Inherited from
Scheduler

Inherited fields

val tasks: SortedSet[TaskInstance]

A sorted queue of tasks that need to be run.

A sorted queue of tasks that need to be run.

Inherited from
PriorityScheduler