Struct LocalExecutor

pub struct LocalExecutor { /* private fields */ }

A single-threaded executor.

Implementations

impl LocalExecutor

pub fn new(notify: impl Fn() + Send + Sync + 'static) -> LocalExecutor

Creates a new single-threaded executor.

Examples

use multitask::LocalExecutor;

let (p, u) = parking::pair();
let ex = LocalExecutor::new(move || u.unpark());

pub fn spawn<T: 'static>( &self, future: impl Future<Output = T> + 'static, ) -> Task<T>

Spawns a thread-local future onto this executor.

Returns a Task handle for the spawned future.

Examples

use multitask::LocalExecutor;

let (p, u) = parking::pair();
let ex = LocalExecutor::new(move || u.unpark());

let task = ex.spawn(async { println!("hello") });

pub fn tick(&self) -> bool

Runs a single task and returns true if one was found.

Examples

use multitask::LocalExecutor;

let (p, u) = parking::pair();
let ex = LocalExecutor::new(move || u.unpark());

assert!(!ex.tick());
let task = ex.spawn(async { println!("hello") });

// This prints "hello".
assert!(ex.tick());

Trait Implementations

impl Debug for LocalExecutor

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

Formats the value using the given formatter.

impl Drop for LocalExecutor

fn drop(&mut self)

Executes the destructor for this type.

impl RefUnwindSafe for LocalExecutor

impl UnwindSafe for LocalExecutor