Trait mz_ore::task::RuntimeExt

pub trait RuntimeExt {
    // Required methods
    fn spawn_blocking_named<Function, Output, Name, NameClosure>(
        &self,
        nc: NameClosure,
        function: Function,
    ) -> JoinHandle<Output> 
       where Name: AsRef<str>,
             NameClosure: FnOnce() -> Name,
             Function: FnOnce() -> Output + Send + 'static,
             Output: Send + 'static;
    fn spawn_named<Fut, Name, NameClosure>(
        &self,
        _nc: NameClosure,
        future: Fut,
    ) -> JoinHandle<Fut::Output> 
       where Name: AsRef<str>,
             NameClosure: FnOnce() -> Name,
             Fut: Future + Send + 'static,
             Fut::Output: Send + 'static;
}

Available on crate feature async only.

Extension methods for Runtime and Handle.

See the module docs for more information.

Required Methods

fn spawn_blocking_named<Function, Output, Name, NameClosure>( &self, nc: NameClosure, function: Function, ) -> JoinHandle<Output>

where Name: AsRef<str>, NameClosure: FnOnce() -> Name, Function: FnOnce() -> Output + Send + 'static, Output: Send + 'static,

Runs the provided closure with a name on a thread where blocking is acceptable.

See tokio::task::spawn_blocking and the module docs for more information.

fn spawn_named<Fut, Name, NameClosure>( &self, _nc: NameClosure, future: Fut, ) -> JoinHandle<Fut::Output>

where Name: AsRef<str>, NameClosure: FnOnce() -> Name, Fut: Future + Send + 'static, Fut::Output: Send + 'static,

Spawns a new asynchronous task with a name.

See tokio::task::spawn and the module docs for more information.

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl RuntimeExt for &Runtime

fn spawn_blocking_named<Function, Output, Name, NameClosure>( &self, nc: NameClosure, function: Function, ) -> JoinHandle<Output>

where Name: AsRef<str>, NameClosure: FnOnce() -> Name, Function: FnOnce() -> Output + Send + 'static, Output: Send + 'static,

fn spawn_named<Fut, Name, NameClosure>( &self, nc: NameClosure, future: Fut, ) -> JoinHandle<Fut::Output>

where Name: AsRef<str>, NameClosure: FnOnce() -> Name, Fut: Future + Send + 'static, Fut::Output: Send + 'static,

impl RuntimeExt for Handle

fn spawn_blocking_named<Function, Output, Name, NameClosure>( &self, nc: NameClosure, function: Function, ) -> JoinHandle<Output>

where Name: AsRef<str>, NameClosure: FnOnce() -> Name, Function: FnOnce() -> Output + Send + 'static, Output: Send + 'static,

fn spawn_named<Fut, Name, NameClosure>( &self, nc: NameClosure, future: Fut, ) -> JoinHandle<Fut::Output>

where Name: AsRef<str>, NameClosure: FnOnce() -> Name, Fut: Future + Send + 'static, Fut::Output: Send + 'static,

impl RuntimeExt for Arc<Runtime>

fn spawn_blocking_named<Function, Output, Name, NameClosure>( &self, nc: NameClosure, function: Function, ) -> JoinHandle<Output>

where Name: AsRef<str>, NameClosure: FnOnce() -> Name, Function: FnOnce() -> Output + Send + 'static, Output: Send + 'static,

fn spawn_named<Fut, Name, NameClosure>( &self, nc: NameClosure, future: Fut, ) -> JoinHandle<Fut::Output>

where Name: AsRef<str>, NameClosure: FnOnce() -> Name, Fut: Future + Send + 'static, Fut::Output: Send + 'static,

Implementors