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 val next: Actionable<T?>?

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

open override fun getNext(): Actionable<T?>?

Retrieve the next scheduled batch of reactions.

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

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.