Enum Runtime

pub enum Runtime {
    Steal(Runtime),
    NoSteal(NoStealRuntime),
}

Pingora async multi-threaded runtime

The Steal flavor is effectively tokio multi-threaded runtime.

The NoSteal flavor is backed by multiple tokio single-threaded runtime.

Variants

Steal(Runtime)

NoSteal(NoStealRuntime)

Implementations

impl Runtime

pub fn new_steal(threads: usize, name: &str) -> Self

Create a Steal flavor runtime. This just a regular tokio runtime

pub fn new_no_steal(threads: usize, name: &str) -> Self

Create a NoSteal flavor runtime. This is backed by multiple tokio current-thread runtime

pub fn get_handle(&self) -> &Handle

Return the &Handle of the Runtime. For Steal flavor, it will just return the &Handle. For NoSteal flavor, it will return the &Handle of a random thread in its pool. So if we want tasks to spawn on all the threads, call this function to get a fresh Handle for each async task.

pub fn shutdown_timeout(self, timeout: Duration)

Call tokio’s shutdown_timeout of all the runtimes. This function is blocking until all runtimes exit.