Struct wlambda::threads::MsgHandle

pub struct MsgHandle { /* fields omitted */ }

This a messaging handle for providing receiver and sender handles for the inter thread communication of WLambda instances.

The communication is internally done either by RPC or by async message passing. The VVal or WLambda values are serialized as msgpack internally for transmission to the other thread. This is not a high speed interface, as serialization and allocations are done.

The communication between WLambda thread instances can be done by multiple senders and multiple receivers, but bear in mind, that in case of RPC one RPC call will lock out all other sender and receiver thread, as RPC calls are synchronous.

Pass this MsgHandle to the receiver thread or multiple threads. You can clone this handle if you want to use it in multiple threads.

See also threads module

Methods

impl MsgHandle

pub fn new() -> Self

pub fn sender(&self) -> Sender

Returns a Sender handle.

pub fn run(&mut self, ctx: &mut EvalContext)

Starts executing Sender requests infinitely long. A global thread:quit function is defined, which can be used to stop this infinitely long loop.

pub fn step(&mut self, ctx: &mut EvalContext, timeout: &Duration) -> Option<()>

Tries to execute a RPC call or received message if the request is received within timeout duration. Returns None if something went wrong. Otherwise Some(()) is returned.

Trait Implementations

impl Clone for MsgHandle

fn clone(&self) -> MsgHandle

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for MsgHandle

fn default() -> Self

Returns the "default value" for a type.