Struct ThreadedExecutor 

pub struct ThreadedExecutor<NID: PartialEq + Send, TID: PartialEq + Send> { /* private fields */ }

Threaded Executor

The Threaded Executor stores nodes in a bunch of SimpleExecutors on given threads. On the update loop each of hte SimpleExecutors execute their nodes in parallel

Implementations

impl<NID: PartialEq + Send, TID: PartialEq + Send> ThreadedExecutor<NID, TID>

pub fn new(interrupt: Receiver<bool>, main_thread_id: TID) -> Self

Create a new Threaded Executor without any Nodes

pub fn new_with( interrupt: Receiver<bool>, main_thread_id: TID, nodes: Vec<(Vec<Box<dyn Node<NID>>>, TID)>, ) -> Self

Creates a new Threaded executor with a given mapping for nodes

Trait Implementations

impl<NID: PartialEq + Send + 'static, TID: PartialEq + Send + 'static> Executor<NID> for ThreadedExecutor<NID, TID>

type Context = TID

Optional Context for adding nodes with specific conditions

fn start(&mut self)

Starts the nodes contained by the executor

fn update_for_ms(&mut self, ms: u128)

Run the update loop for a set amount of time (in milliseconds)

fn update_loop(&mut self)

Run the update loop until the executor’s interrupt is called

fn check_interrupt(&mut self) -> bool

Check whether the program has been interrupted

fn add_node(&mut self, node: Box<dyn Node<NID>>)

Add a node to the executor.

fn add_node_with_context( &mut self, node: Box<dyn Node<NID>>, _ctx: Self::Context, )

Add a node to the executor with some given context.

fn remove_node(&mut self, id: &NID) -> Option<Box<dyn Node<NID>>>

Remove a node from the executor.