R1.2.2

KSLCore/ksl.modeling.entity/TaskProcessingSystem/TaskDispatcher

TaskDispatcher

open inner class TaskDispatcher(parent: ModelElement, name: String? = null, discipline: Queue.Discipline = Discipline.FIFO) : ModelElement(source)

Constructors

constructor(parent: ModelElement, name: String? = null, discipline: Queue.Discipline = Discipline.FIFO)

Properties

endProcessorFailureAction

var endProcessorFailureAction: TaskProcessingSystem.TaskDispatcherActionIfc?

endProcessorInactiveAction

var endProcessorInactiveAction: TaskProcessingSystem.TaskDispatcherActionIfc?

endProcessorWorkAction

var endProcessorWorkAction: TaskProcessingSystem.TaskDispatcherActionIfc?

processorCancelShutdownAction

var processorCancelShutdownAction: TaskProcessingSystem.TaskDispatcherActionIfc?

val processors: List<TaskProcessingSystem.TaskProcessorIfc>

processorShutdownAction

var processorShutdownAction: TaskProcessingSystem.TaskDispatcherActionIfc?

val queue: QueueCIfc<TaskProcessingSystem.Task>

startProcessorFailureAction

var startProcessorFailureAction: TaskProcessingSystem.TaskDispatcherActionIfc?

startProcessorInactiveAction

var startProcessorInactiveAction: TaskProcessingSystem.TaskDispatcherActionIfc?

startProcessorShutdownPendingAction

var startProcessorShutdownPendingAction: TaskProcessingSystem.TaskDispatcherActionIfc?

startProcessorWorkAction

var startProcessorWorkAction: TaskProcessingSystem.TaskDispatcherActionIfc?

Functions

configureTransientTaskProcessorPerformance

fun configureTransientTaskProcessorPerformance(allPerformance: Boolean = false)

Can be used to cause performance statistics to be collected about any transient task processors used by the dispatcher. This function creates model elements. The normal use of this function would be within an init block in order to configure behavior prior to the running of any experiments.

fun hasTask(): Boolean

fun receive(task: TaskProcessingSystem.Task)

Receives tasks and attempts to dispatch them. Selects a processor via the selectProcessor() function and then dispatches the task to the processor with the dispatch() function.

fun register(taskProcessor: TaskProcessingSystem.TaskProcessorIfc)

Registers the processor to receive tasks that are dispatched by the dispatcher.

fun unregister(taskProcessor: TaskProcessingSystem.TaskProcessorIfc): Boolean

Unregisters the processor so that it no longer receives tasks from the dispatcher.