Struct LocalTaskRuntime 

pub struct LocalTaskRuntime<O: Default + 'static = ()>(/* private fields */);

本地异步任务运行时

Implementations

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

pub fn is_running(&self) -> bool

判断当前本地异步任务运行时是否正在运行

pub fn get_id(&self) -> usize

获取当前异步运行时的唯一id

pub fn len(&self) -> usize

获取当前异步运行时任务数量

pub fn spawn<F>(&self, future: F)

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

派发一个指定的异步任务到异步运行时

pub fn send<F>(&self, future: F)

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

线程安全的发送一个异步任务到异步运行时

pub fn poll(&self)

将外部任务队列中的任务移动到内部任务队列

pub fn pipeline<S, SO, F, FO>( &self, input: S, filter: F, ) -> LocalBoxStream<'static, FO>

where S: Stream<Item = SO> + 'static, SO: 'static, F: FnMut(SO) -> AsyncPipelineResult<FO> + 'static, FO: 'static,

生成一个异步管道，输入指定流，输入流的每个值通过过滤器生成输出流的值

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

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

阻塞当前线程，并在当前线程内执行指定的异步任务，返回指定异步任务执行后的结果

pub fn close(self) -> bool

关闭异步运行时，返回请求关闭是否成功

Trait Implementations

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

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

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

impl<O: Default + 'static> !Sync for LocalTaskRuntime<O>