Struct lightproc::lightproc::LightProc

pub struct LightProc { /* fields omitted */ }

Struct to create and operate lightweight processes

Implementations

impl LightProc

pub fn recoverable<F, R, S>(
    future: F,
    schedule: S,
    stack: ProcStack
) -> (LightProc, RecoverableHandle<R>) where
    F: Future<Output = R> + Send + 'static,
    R: Send + 'static,
    S: Fn(LightProc) + Send + Sync + 'static, 

Creates a recoverable process which will signal occurred panic back to the poller.

Example

// ... creating a recoverable process
let panic_recoverable = LightProc::recoverable(
    future,
    schedule_function,
    proc_stack
);

pub fn build<F, R, S>(
    future: F,
    schedule: S,
    stack: ProcStack
) -> (LightProc, ProcHandle<R>) where
    F: Future<Output = R> + Send + 'static,
    R: Send + 'static,
    S: Fn(LightProc) + Send + Sync + 'static, 

Creates a standard process which will stop it’s execution on occurrence of panic.

Example

// ... creating a standard process
let standard = LightProc::build(
    future,
    schedule_function,
    proc_stack
);

pub fn schedule(self)

Schedule the lightweight process with passed schedule function at the build time.

pub fn run(self)

Schedule the lightproc for runnning on the thread.

pub fn cancel(&self)

Cancel polling the lightproc’s inner future, thus cancelling th proc itself.

pub fn stack(&self) -> &ProcStack

Gives a reference to given ProcStack when building the light proc.

Trait Implementations

impl Debug for LightProc

fn fmt(&self, fmt: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for LightProc

fn drop(&mut self)

Executes the destructor for this type.

impl Send for LightProc

impl Sync for LightProc