Trait AsyncRuntimeExt 

pub trait AsyncRuntimeExt<O: Default + 'static = ()> {
    // Required methods
    fn spawn_with_context<F, C>(
        &self,
        task_id: TaskId,
        future: F,
        context: C,
    ) -> Result<()>
       where F: Future<Output = O> + 'static,
             C: 'static;
    fn spawn_timing_with_context<F, C>(
        &self,
        task_id: TaskId,
        future: F,
        context: C,
        time: usize,
    ) -> Result<()>
       where F: Future<Output = O> + 'static,
             C: 'static;
    fn block_on<F>(&self, future: F) -> Result<F::Output>
       where F: Future + 'static,
             <F as Future>::Output: Default + 'static;
}

顺序执行的异步运行时扩展

Required Methods

fn spawn_with_context<F, C>( &self, task_id: TaskId, future: F, context: C, ) -> Result<()>

where F: Future<Output = O> + 'static, C: 'static,

派发一个指定的异步任务到异步运行时，并指定异步任务的初始化上下文

fn spawn_timing_with_context<F, C>( &self, task_id: TaskId, future: F, context: C, time: usize, ) -> Result<()>

where F: Future<Output = O> + 'static, C: 'static,

派发一个在指定时间后执行的异步任务到异步运行时，并指定异步任务的初始化上下文，时间单位ms

fn block_on<F>(&self, future: F) -> Result<F::Output>

where F: Future + 'static, <F as Future>::Output: Default + 'static,

立即创建一个指定任务池的异步运行时，并执行指定的异步任务，阻塞当前线程，等待异步任务完成后返回

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl<O: Default + 'static> AsyncRuntimeExt<O> for LocalTaskRuntime<O>

impl<O: Default + 'static, P: AsyncTaskPoolExt<O> + AsyncTaskPool<O, Pool = P>> AsyncRuntimeExt<O> for SingleTaskRuntime<O, P>

impl<O: Default + 'static, P: AsyncTaskPoolExt<O> + AsyncTaskPool<O, Pool = P>> AsyncRuntimeExt<O> for WorkerRuntime<O, P>