alchemist/it.unibo.alchemist.core/ArrayIndexedPriorityFixedBatchQueue

ArrayIndexedPriorityFixedBatchQueue

Batched extension for ArrayIndexedPriorityQueue. This implementation presents fixed size batches.

concentration type

Constructors

constructor(batchSize: Int, delegate: ArrayIndexedPriorityQueue<T> = ArrayIndexedPriorityQueue())

open override fun addReaction(reaction: Actionable<T>)

Adds a reaction to the data structure.

open override fun getNext(): Actionable<T>

Allows to access the next reaction to be executed.

Retrieve the next scheduled batch of reactions.

open override fun removeReaction(reaction: Actionable<T>)

Removes a reaction from the structure. If the reaction is not present, nothing is done and an Exception is thrown.

open override fun updateReaction(reaction: Actionable<T>)

Notifies the structure that the reaction r has changed. The whole structure will be rearranged to ensure consistency.