Package it.unibo.alchemist.core
Class ArrayIndexedPriorityFixedBatchQueue
-
- All Implemented Interfaces:
-
it.unibo.alchemist.core.BatchedScheduler
,it.unibo.alchemist.core.Scheduler
public final class ArrayIndexedPriorityFixedBatchQueue<T extends Object> implements Scheduler<T>, BatchedScheduler<T>
Batched extension for ArrayIndexedPriorityQueue. This implementation presents fixed size batches.
-
-
Constructor Summary
Constructors Constructor Description ArrayIndexedPriorityFixedBatchQueue(Integer batchSize, ArrayIndexedPriorityQueue<T> delegate)
-
Method Summary
Modifier and Type Method Description List<Actionable<T>>
getNextBatch()
Retrieve the next scheduled batch of reactions. Unit
updateReaction(Actionable<T> reaction)
-
-
Constructor Detail
-
ArrayIndexedPriorityFixedBatchQueue
ArrayIndexedPriorityFixedBatchQueue(Integer batchSize, ArrayIndexedPriorityQueue<T> delegate)
-
-
Method Detail
-
getNextBatch
List<Actionable<T>> getNextBatch()
Retrieve the next scheduled batch of reactions.
- Returns:
batch of reactions to execute
-
updateReaction
Unit updateReaction(Actionable<T> reaction)
-
-
-
-