ports/com.group7.policies.queue/PriorityQueuePolicy

PriorityQueuePolicy

class PriorityQueuePolicy<T : Any>(initialContents: Collection<T> = emptyList(), comparator: Comparator<T>) : QueuePolicy<T>

Priority queue policy. Entities are dequeued according to a priority order defined by the comparator. Lower priority entities (earlier in the comparator order) are dequeued first.

Parameters

the type of entities in the queue

initialContents

the initial entities in the queue

comparator

the Comparator that defines the priority order

Constructors

PriorityQueuePolicy

constructor(initialContents: Collection<T> = emptyList(), comparator: Comparator<T>)

Properties

contents

open override val contents: Sequence<T?>

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

Functions

dequeue

open override fun dequeue(): T

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

enqueue

open override fun enqueue(obj: T)

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 fun supportsResidenceTime(): Boolean

Indicates whether this policy supports residence time tracking for entities.