alchemist-engine/it.unibo.alchemist.core/BatchEngine

BatchEngine

class BatchEngine<T, P : Position<out P>> : Engine<T, P> (source)

This class implements a simulation. It offers a wide number of static factories to ease the creation process.

Parameters

[Position] type

Constructors

BatchEngine

@JvmOverloads

constructor(environment: Environment<T, P>, scheduler: BatchedScheduler<T>, outputReplayStrategy: String = "aggregate")

@JvmOverloads

constructor(environment: Environment<T, P>, scheduler: String, batchSizeOrEpsilon: Number, outputReplayStrategy: String = "aggregate")

Properties

environment

val environment: Environment<T, P>

error

val error: Optional<Throwable>

status

val status: Status

Functions

addOutputMonitor

open override fun addOutputMonitor(op: OutputMonitor<T, P>)

getOutputMonitors

open override fun getOutputMonitors(): MutableList<OutputMonitor<T, P>>

getStep

open override fun getStep(): Long

getTime

open override fun getTime(): Time

goToStep

open override fun goToStep(step: Long): CompletableFuture<Void>

goToTime

open override fun goToTime(t: Time): CompletableFuture<Void>

neighborAdded

open override fun neighborAdded(node: Node<T>, n: Node<T>)

neighborRemoved

open override fun neighborRemoved(node: Node<T>, n: Node<T>)

nodeAdded

open override fun nodeAdded(node: Node<T>)

nodeMoved

open override fun nodeMoved(node: Node<T>)

nodeRemoved

open override fun nodeRemoved(node: Node<T>, oldNeighborhood: Neighborhood<T>)

pause

open override fun pause(): CompletableFuture<Void>

play

open override fun play(): CompletableFuture<Void>

reactionAdded

open override fun reactionAdded(reactionToAdd: Actionable<T>)

reactionRemoved

open override fun reactionRemoved(reactionToRemove: Actionable<T>)

removeOutputMonitor

open override fun removeOutputMonitor(op: OutputMonitor<T, P>)

run

open override fun run()

schedule

open override fun schedule(runnable: CheckedRunnable)

terminate

open override fun terminate(): CompletableFuture<Void>

toString

open override fun toString(): String

waitFor

open override fun waitFor(next: Status, timeout: Long, tu: TimeUnit): Status