ports/com.group7.policies.queue/TokenQueuePolicy

TokenQueuePolicy

class TokenQueuePolicy(count: Int) : QueuePolicy<Token>

Token queue policy. Manages a pool of abstract tokens used for flow control. Rather than storing actual entities, tracks token availability. Does not support residence time tracking since tokens are not individual entities.

Parameters

count

the initial number of tokens available

Constructors

TokenQueuePolicy

constructor(count: Int)

Properties

contents

open override val contents: Sequence<Token>

A sequence of all entities currently in the queue, in their stored order.

Functions

dequeue

open override fun dequeue(): Token

Removes and returns an entity from the queue according to the policy.

enqueue

open override fun enqueue(obj: Token)

Adds an entity to the queue according to the policy.

reportOccupancy

open override fun reportOccupancy(): Int

Reports the current number of entities in the queue.

supportsResidenceTime

open override fun supportsResidenceTime(): Boolean

Indicates whether this policy supports residence time tracking for entities.