Struct AsyncTaskTimerByNotCancel 

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

异步任务本地定时器，不支持取消定时任务

Implementations

impl<P: AsyncTaskPoolExt<O> + AsyncTaskPool<O>, O: Default + 'static> AsyncTaskTimerByNotCancel<P, O>

pub fn new() -> Self

构建异步任务本地定时器

pub fn get_producor(&self) -> &Sender<(usize, AsyncTimingTask<P, O>)>

获取定时任务生产者

pub fn len(&self) -> usize

获取剩余未到期的定时器任务数量

pub fn set_timer(&self, task: AsyncTimingTask<P, O>, timeout: usize)

设置定时器

pub fn consume(&self) -> usize

消费所有定时任务，返回定时任务数量

pub fn is_require_pop(&self) -> Option<u64>

判断当前时间是否有可以弹出的任务，如果有可以弹出的任务，则返回当前时间，否则返回空

pub fn pop(&self, current_time: u64) -> Option<AsyncTimingTask<P, O>>

从定时器中弹出指定时间的一个到期任务

Trait Implementations

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

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