Struct kumo_server_runtime::Runtime

pub struct Runtime { /* private fields */ }

Implementations

impl Runtime

pub fn new<F>( name_prefix: &'static str, default_size: F, configured_size: &AtomicUsize, ) -> Result<Self>

where F: FnOnce(usize) -> usize,

pub fn get_num_threads(&self) -> usize

pub async fn spawn<F: FnOnce() -> Result<FUT> + Send + 'static, FUT>( &self, name: String, func: F, ) -> Result<JoinHandle<FUT::Output>>

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

Schedule func to run in the runtime pool. func must return a future; that future will be spawned into the thread-local executor. This function will return the result of the spawn attempt, but will not wait for the future it spawns to complete.

This function is useful for getting into a localset environment where !Send futures can be scheduled when you are not already in such an environment.

If you are already in a !Send future, then using spawn_local below has less overhead.

pub fn spawn_non_blocking<F: FnOnce() -> Result<FUT> + Send + 'static, FUT>( &self, name: String, func: F, ) -> Result<()>

where FUT: Future + 'static,

Trait Implementations

impl Drop for Runtime

fn drop(&mut self)

Executes the destructor for this type.