Struct RuntimeManager

pub struct RuntimeManager { /* private fields */ }

Available on crate feature async only.

Implementations

impl RuntimeManager

pub fn block_in_place_on<F>(&self, future: F) -> F::Output

where F: Future,

Shorthand for tokio::task::block_in_place(|| block_on(f)). This is a variant of block_on that is safe to call from if the current thread has already entered the async runtime, or is a rayon thread.

Safety

The tokio runtime flavor is multi-threaded.

pub fn block_on<F>(&self, future: F) -> F::Output

where F: Future,

Note: block_in_place_on should be used instead if the current thread is a rayon thread or has already entered the async runtime.

pub fn spawn<F>(&self, future: F) -> JoinHandle<F::Output>

where F: Future + Send + 'static, F::Output: Send + 'static,

Spawns a future onto the Tokio runtime (see [tokio::runtime::Runtime::spawn]).

pub fn spawn_blocking<F, R>(&self, f: F) -> JoinHandle<R>

where F: FnOnce() -> R + Send + 'static, R: Send + 'static,

pub async fn spawn_rayon<F, O>(&self, func: F) -> O

where F: FnOnce() -> O + Send + Sync + 'static, O: Send + Sync + 'static,

Run a task on the rayon threadpool. To avoid deadlocks, if the current thread is already a rayon thread, the task is executed on the current thread after tokio’s block_in_place is used to spawn another thread to poll futures.