Struct WorkerTaskRunner 

pub struct WorkerTaskRunner<O: Default + 'static = (), P: AsyncTaskPoolExt<O> + AsyncTaskPool<O, Pool = P> = SingleTaskPool<O>>(/* private fields */);

工作者任务执行器

Implementations

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

pub fn new( pool: P, worker_status: Arc<AtomicBool>, worker_waker: Arc<(AtomicBool, Mutex<()>, Condvar)>, ) -> Self

用指定的任务池构建工作者任务执行器

pub fn get_runtime(&self) -> WorkerRuntime<O, P>

获取当前工作者异步任务执行器的工作者运行时

pub fn run_once(&self) -> Result<usize>

运行一次工作者异步任务执行器，返回当前任务池中任务的数量

pub fn run(&self) -> Result<usize>

运行单线程异步任务执行器，并执行任务池中的所有任务

pub fn startup<LF, GQL>( self, thread_name: &str, thread_stack_size: usize, sleep_timeout: u64, loop_interval: Option<u64>, loop_func: LF, get_queue_len: GQL, ) -> WorkerRuntime<O, P>

where P: AsyncTaskPoolExt<O> + AsyncTaskPool<O, Pool = P>, LF: Fn() -> (bool, Duration) + Send + 'static, GQL: Fn() -> usize + Send + 'static,

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

Trait Implementations

impl<O: Default + 'static, P: AsyncTaskPoolExt<O> + AsyncTaskPool<O, Pool = P>> Clone for WorkerTaskRunner<O, P>

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> Default for WorkerTaskRunner<O>

fn default() -> Self

Returns the “default value” for a type.

impl<O: Default + 'static, P: AsyncTaskPoolExt<O> + AsyncTaskPool<O, Pool = P>> Send for WorkerTaskRunner<O, P>

impl<O: Default + 'static, P: AsyncTaskPoolExt<O> + AsyncTaskPool<O, Pool = P>> Sync for WorkerTaskRunner<O, P>