Struct LocalExecutionEngine 

pub struct LocalExecutionEngine { /* private fields */ }

Implementations

impl LocalExecutionEngine

pub fn new( inner: Rc<ExecutorState>, activities: Option<Sender<ThreadActivity>>, ) -> Self

Trait Implementations

impl Clone for LocalExecutionEngine

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<'a> ExecutionEngine for Box<&'a LocalExecutionEngine>

fn lift( &self, task: BoxedExecutionIterator, parent: Option<Entry>, ) -> AnyResult<SpawnInfo, ExecutorError>

lift prioritizes an incoming task to the top of the local execution queue which pauses all processing task till that point till the new task is done or goes to sleep (dependent on the internals of the ExecutionEngine).

fn sequenced( &self, task: BoxedExecutionIterator, parent: Entry, ) -> AnyResult<SpawnInfo, ExecutorError>

sequenced prioritizes an incoming task to the top of the local execution queue as a sequential operation that links both this task and parent into a execution loop where one execution of the task must lead to the execution of the parent as well.

fn schedule( &self, task: BoxedExecutionIterator, ) -> AnyResult<SpawnInfo, ExecutorError>

schedule adds provided incoming task to the bottom of the local execution queue which pauses all processing task till that point till the new task is done or goes to sleep (dependent on the internals of the ExecutionEngine).

fn broadcast(&self, task: GlobalTask) -> AnyResult<SpawnInfo, ExecutorError>

broadcast allows you to deliver a task to the global execution queue which then lets the giving task to be sent of to the same or another executor in another thread for processing, which requires the type to be Send safe.

fn shared_queue(&self) -> SharedTaskQueue

shared_queue returns access to the global queue.

fn boxed_engine(&self) -> BoxedExecutionEngine

boxed_engine returns a instance of the engine as a BoxedExecutionEngine.

fn rng(&self) -> Rc<RefCell<ChaCha8Rng>>

rng returns a shared thread-safe ChaCha8Rng random generation managed by the executor.

fn broadcast_or_lift( &self, task: GlobalTask, parent: Option<Entry>, ) -> AnyResult<SpawnInfo, ExecutorError>

broadcast_or_lift dispatches a task based on the execution mode:

fn broadcast_or_sequence( &self, task: GlobalTask, parent: Entry, ) -> AnyResult<SpawnInfo, ExecutorError>

broadcast_or_sequence dispatches a task based on the execution mode:

impl ExecutionEngine for Box<LocalExecutionEngine>

fn sequenced( &self, task: BoxedExecutionIterator, parent: Entry, ) -> AnyResult<SpawnInfo, ExecutorError>

sequenced prioritizes an incoming task to the top of the local execution queue as a sequential operation that links both this task and parent into a execution loop where one execution of the task must lead to the execution of the parent as well.

fn lift( &self, task: BoxedExecutionIterator, parent: Option<Entry>, ) -> AnyResult<SpawnInfo, ExecutorError>

lift prioritizes an incoming task to the top of the local execution queue which pauses all processing task till that point till the new task is done or goes to sleep (dependent on the internals of the ExecutionEngine).

fn schedule( &self, task: BoxedExecutionIterator, ) -> AnyResult<SpawnInfo, ExecutorError>

schedule adds provided incoming task to the bottom of the local execution queue which pauses all processing task till that point till the new task is done or goes to sleep (dependent on the internals of the ExecutionEngine).

fn broadcast(&self, task: GlobalTask) -> AnyResult<SpawnInfo, ExecutorError>

broadcast allows you to deliver a task to the global execution queue which then lets the giving task to be sent of to the same or another executor in another thread for processing, which requires the type to be Send safe.

fn shared_queue(&self) -> SharedTaskQueue

shared_queue returns access to the global queue.

fn boxed_engine(&self) -> BoxedExecutionEngine

boxed_engine returns a instance of the engine as a BoxedExecutionEngine.

fn rng(&self) -> Rc<RefCell<ChaCha8Rng>>

rng returns a shared thread-safe ChaCha8Rng random generation managed by the executor.

fn broadcast_or_lift( &self, task: GlobalTask, parent: Option<Entry>, ) -> AnyResult<SpawnInfo, ExecutorError>

broadcast_or_lift dispatches a task based on the execution mode:

fn broadcast_or_sequence( &self, task: GlobalTask, parent: Entry, ) -> AnyResult<SpawnInfo, ExecutorError>

broadcast_or_sequence dispatches a task based on the execution mode:

impl ExecutionEngine for LocalExecutionEngine

fn shared_queue(&self) -> SharedTaskQueue

shared_queue returns access to the global queue.

fn rng(&self) -> Rc<RefCell<ChaCha8Rng>>

rng returns the local executor random number generator.

fn sequenced( &self, task: BoxedExecutionIterator, parent: Entry, ) -> AnyResult<SpawnInfo, ExecutorError>

sequenced prioritizes an incoming task to the top of the local execution queue as a sequential operation that links both this task and parent into a execution loop where one execution of the task must lead to the execution of the parent as well.

fn lift( &self, task: BoxedExecutionIterator, parent: Option<Entry>, ) -> AnyResult<SpawnInfo, ExecutorError>

lift prioritizes an incoming task to the top of the local execution queue which pauses all processing task till that point till the new task is done or goes to sleep (dependent on the internals of the ExecutionEngine).

fn schedule( &self, task: BoxedExecutionIterator, ) -> AnyResult<SpawnInfo, ExecutorError>

schedule adds provided incoming task to the bottom of the local execution queue which pauses all processing task till that point till the new task is done or goes to sleep (dependent on the internals of the ExecutionEngine).

fn broadcast(&self, task: GlobalTask) -> AnyResult<SpawnInfo, ExecutorError>

broadcast allows you to deliver a task to the global execution queue which then lets the giving task to be sent of to the same or another executor in another thread for processing, which requires the type to be Send safe.

fn boxed_engine(&self) -> BoxedExecutionEngine

boxed_engine returns a instance of the engine as a BoxedExecutionEngine.

fn broadcast_or_lift( &self, task: GlobalTask, parent: Option<Entry>, ) -> AnyResult<SpawnInfo, ExecutorError>

broadcast_or_lift dispatches a task based on the execution mode:

fn broadcast_or_sequence( &self, task: GlobalTask, parent: Entry, ) -> AnyResult<SpawnInfo, ExecutorError>

broadcast_or_sequence dispatches a task based on the execution mode: