Struct NoStealRuntime

pub struct NoStealRuntime { /* private fields */ }

Multi-threaded runtime backed by a pool of single threaded tokio runtime

Implementations

impl NoStealRuntime

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

Create a new NoStealRuntime. Panic if threads is 0

pub fn get_runtime(&self) -> &Handle

Return the &Handle of a random thread of this runtime

pub fn threads(&self) -> usize

Return the number of threads of this runtime

pub fn get_runtime_at(&self, index: usize) -> &Handle

Return the &Handle of a given thread of this runtime

pub fn shutdown_timeout(self, timeout: Duration)

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