Enum fuse_backend_rs::common::async_runtime::Runtime

pub enum Runtime {
    Tokio(Runtime),
    Uring(Mutex<Runtime>),
}

An adapter enum to support both tokio current-thread Runtime and tokio-uring Runtime.

Variants

Tokio(Runtime)

Tokio current thread Runtime.

Uring(Mutex<Runtime>)

Tokio-uring Runtime.

Implementations

impl Runtime

pub fn new() -> Self

Create a new instance of async Runtime.

A tokio-uring::Runtime is create if io-uring is available, otherwise a tokio current thread Runtime will be created.

Panic

Panic if failed to create the Runtime object.

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

Run a future to completion.

pub fn spawn<T: Future + 'static>(&self, task: T) -> JoinHandle<T::Output>

Spawns a new asynchronous task, returning a JoinHandle for it.

Spawning a task enables the task to execute concurrently to other tasks. There is no guarantee that a spawned task will execute to completion. When a runtime is shutdown, all outstanding tasks are dropped, regardless of the lifecycle of that task.

This function must be called from the context of a tokio-uring runtime.

Trait Implementations

impl Default for Runtime

fn default() -> Self

Returns the “default value” for a type.