Struct LocalTaskRunner 

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

本地异步任务执行器

Implementations

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

pub fn new() -> Self

构建本地异步任务执行器

pub fn with_poll(poller: Arc<Poller>) -> Self

构建一个指定了Poller的本地异步任务执行器 注意当异步任务执行器在运行时，外部不允许使用wait方法

pub fn is_with_polling(&self) -> bool

判断是指定使用Poll

pub fn get_runtime(&self) -> LocalTaskRuntime<O>

获取当前本地异步任务执行器的运行时

pub fn startup( self, thread_name: &str, thread_stack_size: usize, ) -> LocalTaskRuntime<O>

启动工作者异步任务执行器

pub fn startup_with_poll( self, thread_name: &str, thread_stack_size: usize, try_count: usize, timeout: Option<Duration>, ) -> LocalTaskRuntime<O>

启动设置了Poller的工作者异步任务执行器

pub fn poll(&self)

将外部任务队列中的任务移动到内部任务队列 注意应该在执行run_once之前调用

pub fn run_once(&self)

运行一次本地异步任务执行器

pub fn try_sleep( &self, try_count: usize, timeout: Option<Duration>, ) -> IOResult<Option<usize>>

尝试休眠当前推动运行时的线程，并在派发新任务或休眠超时后唤醒 返回Some表示还需要至少多少次尝试以后才可能休眠 注意休眠只在设置了Poller后有效，且在执行run_once后调用

pub fn into_local(self) -> LocalTaskRuntime<O>

转换为本地异步任务运行时

Trait Implementations

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

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