PriorityScheduler

abstract
class PriorityScheduler(using ordering: Ordering[TaskInstance]) extends Scheduler

A Scheduler trait that uses a SortedSet.

Forms the basis for priority-based schedulers.

trait Scheduler
class Object
trait Matchable
class Any

Value members

Concrete methods

override
def addTask(task: TaskInstance): Unit

Adds a TaskInstance to be scheduled.

Adds a TaskInstance to be scheduled.

Definition Classes
override
def getTasks(): Iterable[TaskInstance]

Retrieves an iterable collection of queued TaskInstances.

Retrieves an iterable collection of queued TaskInstances.

Definition Classes
override
def noMoreTasks(): Boolean

Checks if all Tasks have been scheduled.

Checks if all Tasks have been scheduled.

Definition Classes
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
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 methods

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
def getNextTasks(currentTime: Long, resourceMap: Map[String, TaskResource]): Seq[TaskInstance]

Determines which TaskInstances to start next.

Determines which TaskInstances to start next.

TaskInstances are assumed to be sorted by priority.

Value Params
currentTime

The current timestamp.

resourceMap

The map of available TaskResources.

tasks

The queue of TaskInstances waiting to be started.

Returns

The sequence of TaskInstances to start now.

Inherited from
Scheduler
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
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
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

Concrete 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.