alchemist/it.unibo.alchemist.core/BatchEngine

BatchEngine

class BatchEngine<T, P : Position<out P>> : Engine<T, P>

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")

Types

Companion

object Companion

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()

runInCurrentThread

@JvmStatic

fun <T, P : Position<P>> Simulation<T, P>.runInCurrentThread(): Simulation<T, P>

Runs an existing Simulation in the current thread.

schedule

open override fun schedule(runnable: CheckedRunnable)

startSimulation

fun <T, P : Position<P>, Vector<P>> Simulation<T, P>.startSimulation(onceInitialized: (EuclideanEnvironment<T, P>) -> Unit = { }, atEachStep: (EuclideanEnvironment<T, P>, Actionable<T>?, Time, Long) -> Unit = { _, _, _, _ -> }, whenFinished: (EuclideanEnvironment<T, P>, Time, Long) -> Unit = { _, _, _ -> }, steps: Long = 10000): EuclideanEnvironment<T, P>

Run the simulation this environment owns.

terminate

open override fun terminate(): CompletableFuture<Void>

terminatingAfterSteps

@JvmStatic

fun <T, P : Position<P>> Simulation<T, P>.terminatingAfterSteps(finalStep: Long): Simulation<T, P>

toGraphQLSimulationSurrogate

fun <T, P : Position<out P>> Simulation<T, P>.toGraphQLSimulationSurrogate(): SimulationSurrogate<T, P>

Converts a Simulation to a SimulationSurrogate.

toString

open override fun toString(): String

waitFor

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