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

Engine

open class Engine<T, P : Position<out P>>(environment: Environment<T, P>, scheduler: Scheduler<T>) : Simulation<T, P> (source)

Represents a simulation engine that manages execution and scheduling. Provides multiple factory methods to simplify the creation process.

Parameters

the concentration type

the position type, extending Position

Inheritors

BatchEngine

Constructors

Engine

constructor(environment: Environment<T, P>)

Constructs a simulation with a default scheduler.

constructor(environment: Environment<T, P>, scheduler: Scheduler<T>)

Functions

addOutputMonitor

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

Adds an output monitor to track simulation events.

getEnvironment

open override fun getEnvironment(): Environment<T, P>

getError

open override fun getError(): Optional<Throwable>

getOutputMonitors

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

getStatus

open override fun getStatus(): Status

getStep

@Synchronized

open override fun getStep(): Long

getTime

@Synchronized

open override fun getTime(): Time

goToStep

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

Moves the simulation forward until the given step is reached.

goToTime

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

Moves the simulation forward until the given time is reached.

neighborAdded

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

Registers a newly added neighbor.

neighborRemoved

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

Registers a removed neighbor.

nodeAdded

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

Handles the addition of a new node.

nodeMoved

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

Handles node movement.

nodeRemoved

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

Handles the removal of a node.

pause

open override fun pause(): CompletableFuture<Unit>

Pauses the simulation.

play

open override fun play(): CompletableFuture<Unit>

Resumes the simulation.

reactionAdded

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

Registers a newly added reaction.

reactionRemoved

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

Registers a removed reaction.

removeOutputMonitor

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

run

open override fun run()

Runs the simulation.

schedule

open override fun schedule(runnable: CheckedRunnable)

Schedules a task for execution.

terminate

open override fun terminate(): CompletableFuture<Unit>

Terminates the simulation.

toString

open override fun toString(): String

waitFor

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

Waits for the simulation to reach a given status.