Struct MultiTaskRuntimeBuilder 

pub struct MultiTaskRuntimeBuilder<O: Default + 'static = (), P: AsyncTaskPoolExt<O> + AsyncTaskPool<O> = StealableTaskPool<O>> { /* private fields */ }

异步多线程任务运行时构建器

Implementations

impl<O: Default + 'static, P: AsyncTaskPoolExt<O> + AsyncTaskPool<O, Pool = P>> MultiTaskRuntimeBuilder<O, P>

pub fn new(pool: P) -> Self

构建指定任务池、线程名前缀、初始线程数量、最少线程数量、最大线程数量、线程栈大小、线程空闲时最长休眠时间和是否使用本地定时器的多线程任务池

pub fn thread_prefix(self, prefix: &str) -> Self

设置工作者线程名称前缀

pub fn thread_stack_size(self, stack_size: usize) -> Self

设置工作者线程栈大小

pub fn init_worker_size(self, init: usize) -> Self

设置初始工作者数量

pub fn set_worker_limit(self, min: usize, max: usize) -> Self

设置最小工作者数量和最大工作者数量

pub fn set_timeout(self, timeout: u64) -> Self

设置工作者空闲时最大休眠时长

pub fn set_timer_interval(self, interval: usize) -> Self

设置工作者定时器间隔

pub fn build(self) -> MultiTaskRuntime<O, P>

构建并启动多线程异步运行时

Trait Implementations

impl<O: Default + 'static> Default for MultiTaskRuntimeBuilder<O>

fn default() -> Self

Returns the “default value” for a type.

impl<O: Default + 'static, P: AsyncTaskPoolExt<O> + AsyncTaskPool<O>> Send for MultiTaskRuntimeBuilder<O, P>

impl<O: Default + 'static, P: AsyncTaskPoolExt<O> + AsyncTaskPool<O>> Sync for MultiTaskRuntimeBuilder<O, P>