ports/com.group7.nodes/QueueNode

QueueNode

class QueueNode<T>(label: String, source: PushInputChannel<T>, destination: PullOutputChannel<T>, policy: QueuePolicy<T> = FIFOQueuePolicy()) : ContainerNode<T> , Queue<T>

A queue that receives entities through a push channel and outputs them through a pull channel. Entities are stored and ordered according to the provided QueuePolicy (defaults to FIFO). The queue remains open to receive entities and signals readiness when it contains items.

Parameters

T

the type of entities in the queue

label

the name of this node

source

the input channel from which entities are received

destination

the output channel where entities are sent

policy

the QueuePolicy that determines entity ordering (defaults to FIFO)

Constructors

constructor(label: String, source: PushInputChannel<T>, destination: PullOutputChannel<T>, policy: QueuePolicy<T> = FIFOQueuePolicy())

Properties

override val incoming: List<InputChannel<*, *>>

val label: String

open override val occupants: Int

Returns the current number of entities in the queue.

override val outgoing: List<OutputChannel<*, *>>

val parent: NodeGroup?

val stackTrace: List<StackTraceElement?>

Functions

open override fun onEnter(callback: context(Simulator) (T) -> Unit)

Registers a callback to be invoked when an entity enters this container.

open override fun onLeave(callback: context(Simulator) (T) -> Unit)

Registers a callback to be invoked when an entity leaves this container.

context(_: Simulator)
open override fun onStart()

Initializes the queue, marking destination ready if there are initial occupants.

open fun properties(): List<DisplayProperty>

supportsResidenceTime

open override fun supportsResidenceTime(): Boolean

Checks if the QueuePolicy supports residence time tracking.

open override fun toString(): String