Struct LocalTaskRuntime 

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

兼容wasm的本地单线程异步运行时

Implementations

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

pub fn is_running(&self) -> bool

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

pub fn internal_len(&self) -> usize

获取当前内部任务的数量

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

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

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

Trait Implementations

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

fn spawn_yield_by_id<F>(&self, task_id: TaskId, future: F) -> Result<()>

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

派发一个指定任务唯一id的异步任务到异步运行时，并立即让出任务的当前运行

fn spawn_timing_by_id<F>( &self, _task_id: TaskId, _future: F, _time: usize, ) -> Result<()>

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

派发一个指定任务唯一id和在指定时间后执行的异步任务到异步运行时，时间单位ms

fn pending<Output: 'static>( &self, task_id: &TaskId, waker: Waker, ) -> Poll<Output>

挂起指定唯一id的异步任务

fn wakeup<Output: 'static>(&self, task_id: &TaskId)

唤醒指定唯一id的异步任务

fn wait<V: 'static>(&self) -> AsyncWait<V>

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

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

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

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

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

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

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

fn timeout(&self, _timeout: usize) -> LocalBoxFuture<'static, ()>

挂起当前异步运行时的当前任务，等待指定的时间后唤醒当前任务

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

立即让出当前任务的执行

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,

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

fn close(&self) -> bool

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

type Pool = LocalTaskPool<O>

fn shared_pool(&self) -> Arc<Self::Pool>

共享运行时内部任务池

fn get_id(&self) -> usize

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

fn wait_len(&self) -> usize

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

fn len(&self) -> usize

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

fn alloc<R: 'static>(&self) -> TaskId

分配异步任务的唯一id

fn spawn<F>(&self, future: F) -> Result<TaskId>

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

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

fn spawn_local<F>(&self, future: F) -> Result<TaskId>

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

派发一个异步任务到本地异步运行时，如果本地没有本异步运行时，则会派发到当前运行时中

fn spawn_priority<F>(&self, priority: usize, future: F) -> Result<TaskId>

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

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

fn spawn_yield<F>(&self, future: F) -> Result<TaskId>

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

派发一个异步任务到异步运行时，并立即让出任务的当前运行

fn spawn_timing<F>(&self, future: F, time: usize) -> Result<TaskId>

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

派发一个在指定时间后执行的异步任务到异步运行时，时间单位ms

fn spawn_by_id<F>(&self, task_id: TaskId, future: F) -> Result<()>

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

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

fn spawn_local_by_id<F>(&self, task_id: TaskId, future: F) -> Result<()>

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

派发一个指定任务唯一id的异步任务到本地异步运行时，如果本地没有本异步运行时，则会派发到当前运行时中

fn spawn_priority_by_id<F>( &self, task_id: TaskId, _priority: usize, future: F, ) -> Result<()>

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

派发一个指定任务唯一id和任务优先级的异步任务到异步运行时

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

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,

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

fn spawn_with_context<F, C>( &self, _task_id: TaskId, _future: F, _context: C, ) -> Result<()>

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

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

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.