ArrayIndexedPriorityFixedBatchQueue

class ArrayIndexedPriorityFixedBatchQueue<T>(batchSize: Int, delegate: ArrayIndexedPriorityQueue<T> = ArrayIndexedPriorityQueue()) : Scheduler<T> , BatchedScheduler<T>

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

Parameters

concentration type

Constructors

Link copied to clipboard
constructor(batchSize: Int, delegate: ArrayIndexedPriorityQueue<T> = ArrayIndexedPriorityQueue())

Functions

Link copied to clipboard
open override fun addReaction(p0: Actionable<T>)
Link copied to clipboard
open override fun getNext(): Actionable<T>
Link copied to clipboard
open override fun getNextBatch(): List<Actionable<T>>

Retrieve the next scheduled batch of reactions.

Link copied to clipboard
open override fun removeReaction(p0: Actionable<T>)
Link copied to clipboard
open override fun updateReaction(reaction: Actionable<T>)