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 wait<V: 'static>(&self) -> AsyncWait<V>

挂起当前异步运行时的当前任务，并在指定的其它运行时上派发一个指定的异步任务，等待其它运行时上的异步任务完成后，唤醒当前运行时的当前任务，并返回其它运行时上的异步任务的值

pub fn wait_any<V: 'static>(&self, capacity: usize) -> AsyncWaitAny<V>

挂起当前异步运行时的当前任务，并在多个其它运行时上执行多个其它任务，其中任意一个任务完成，则唤醒当前运行时的当前任务，并返回这个已完成任务的值，而其它未完成的任务的值将被忽略

pub fn wait_any_callback<V: 'static>( &self, capacity: usize, ) -> AsyncWaitAnyCallback<V>

挂起当前异步运行时的当前任务，并在多个其它运行时上执行多个其它任务，任务返回后需要通过用户指定的检查回调进行检查，其中任意一个任务检查通过，则唤醒当前运行时的当前任务，并返回这个已完成任务的值，而其它未完成或未检查通过的任务的值将被忽略，如果所有任务都未检查通过，则强制唤醒当前运行时的当前任务

pub fn map_reduce<V: 'static>(&self, capacity: usize) -> AsyncMapReduce<V>

构建用于派发多个异步任务到指定运行时的映射归并，需要指定映射归并的容量

pub fn yield_now(&self) -> LocalBoxFuture<'static, ()>

立即让出当前任务的执行

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>