Struct Runtime 

pub struct Runtime { /* private fields */ }

Implementations

impl Runtime

pub fn new() -> Self

pub fn new_with_threads(num_os_threads: NonZeroUsize) -> Self

pub fn block_on<T: Send + 'static, F: Future<Output = T> + Send + 'static>( &self, task: F, ) -> T

Blocks the current thread until the runtime has finished th task

pub unsafe fn unsafe_block_on<T: Send + 'static, F: Future<Output = T> + 'static>( &self, task: F, ) -> T

Blocks the current thread until the runtime has finished th task (unsafe version)

Safety

Make sure task is Send before polled for the first time (Can be not Send afterwards)

pub fn spawn<F: Future<Output = ()> + Send + 'static>(&self, task: F)

Spawns the task on a random thread

pub fn get_num_threads(&self) -> usize

How many worker threads are there?

pub fn spawn_at<F: Future<Output = ()> + Send + 'static>( &self, offset: usize, task: F, )

Spawns the task on a specific thread

pub unsafe fn unsafe_spawn_at<F: Future<Output = ()> + 'static>( &self, offset: usize, task: F, )

Safety

Make sure task is Send before polled for the first time (Can be not Send afterwards)

pub unsafe fn unsafe_spawn<F: Future<Output = ()> + 'static>(&self, task: F)

Safety

Make sure task is Send before polled for the first time (Can be not Send afterwards)

pub fn new_spawn_ring(&self) -> SpawnRing

Create a primitive that lets you distribute tasks across worker threads in a round-robin fashion

Trait Implementations

impl Default for Runtime

fn default() -> Self

Returns the “default value” for a type.

impl Drop for Runtime

fn drop(&mut self)

Executes the destructor for this type.