Struct ThreadedExecutor

pub struct ThreadedExecutor<'a, D, S>
where
    D: DomainWithPlanningTask + GlobalDomain,
    D::State: Clone + Send,
    D::Diff: Send + Sync,
    S: ExecutorState<D> + ExecutorStateGlobal<D>,
{ /* private fields */ }

A multi-threaded generic executor.

It maintains a D::GlobalState out of which a D::State is derived for planning. This allows to simulate a large world with many agents, each of them planning on a small subset of that world. The helper function run_threaded_executor can create and run it for you.

Implementations

impl<'a, D, S> ThreadedExecutor<'a, D, S>

where D: DomainWithPlanningTask + GlobalDomain, D::State: Clone + Send, D::Diff: Send + Sync, S: ExecutorState<D> + ExecutorStateGlobal<D>,

pub fn new(mcts_config: MCTSConfiguration, executor_state: &'a mut S) -> Self

Creates a new executor, initializes state and task queue from the S trait.

pub fn step(&mut self) -> bool

Executes all tasks finishing at the current tick and then increments it.

Returns whether execution should continue.

pub fn stop(&mut self)

Makes all planning threads stop and wait for them to finish.

pub fn state(&self) -> &D::GlobalState

Gets the global state, read-only.

pub fn agents_count(&self) -> usize

Gets the number of active agents in the execution queue.