Struct LocalTimer 

pub struct LocalTimer<T, const N1: usize, const N2: usize, const N3: usize, const N4: usize> {
    pub frame_time: u64,
    pub start_time: u64,
    pub roll_time: u64,
    pub index_factory: SlabFactory<usize, ()>,
    pub frame_wheel: FrameWheel<T, N1, N2, N3, N4>,
}

任务轮实现的延时任务管理

• T 延时任务的数据类型
• N1 一级粒度轮的槽位数 <任务轮分4级粒度>
• N2 二级粒度轮的槽位数 <任务轮分4级粒度>
• N3 三级粒度轮的槽位数 <任务轮分4级粒度>
• N4 四级粒度轮的槽位数 <任务轮分4级粒度>
• N1 到 N4 依次减少, 总数不应超过 usize 范围

Example

let mut timer = LocalTimer::<i32, 100, 60, 60, 24>::new(10, run_millis());
// 插入一个任务 - 数据为 55, 延时为 1000ms
let timeout_handler = timer.insert(Item::new(55 as i32, 1000 as u64));
// 尝试获取一个超时任务
let one_task_option = timer.pop();
// 当获取到的任务为空，可以检查可休眠时间
let sleep_time = timer.check_sleep(now);
// 可移除一个任务
let item_option = timer.try_remove(timeout_handler);

Fields

frame_time: u64

最小粒度世界线的帧间隔

start_time: u64

启动时间

roll_time: u64

滚动的累积时间

index_factory: SlabFactory<usize, ()>

Index 工厂

frame_wheel: FrameWheel<T, N1, N2, N3, N4>

帧进度的任务轮

Implementations

impl<T, const N1: usize, const N2: usize, const N3: usize, const N4: usize> LocalTimer<T, N1, N2, N3, N4>

pub fn new(frame_time: u64, now: u64) -> Self

Create a wheel to support four rounds.

• frame_time 最小时间间隔 - 单位毫秒
• now 当前绝对时间
• tip frame_time 与 N1..N4 之积 的乘积不应超过 uszie 范围

Error Example

// 当 usize 最大 2**32, 则下面的创建不保证运行正确，且可能崩溃
let mut timer = WheelTimer::<i32, 100, 60, 60, 24>::new(1000, run_millis()); // 100*60*60*24*1000 = 8640000000 > 2**32

pub fn check_sleep(&self, now: u64) -> u64

检查可休眠时间

• now 当前线程时间 <与创建时设置的 now 属于同一时间进度>

pub fn len(&self) -> usize

总任务数量

pub fn get_time(&mut self) -> u64

当前运行时长

pub fn insert(&mut self, data: T, timeout: u64) -> usize

插入元素

• data 目标数据
• timeout 延时时间 - 单位毫秒

pub fn clear(&mut self)

clear all elem

pub fn pop(&mut self, now: u64) -> Option<(TimeoutItem<T>, usize)>

弹出一个超时任务 - 当没有任务弹出，经过检查需要做一次滚动则进行一次滚动 - 当没有任务弹出，外部可以检查睡眠时间

• now 当前时间

pub fn try_remove(&mut self, index: usize) -> Option<TimeoutItem<T>>

移除一个任务

• index 任务插入时返回的 index

pub fn remove(&mut self, index: usize) -> Option<TimeoutItem<T>>

Panics if index is out of bounds. 移除一个任务

• index 任务插入时返回的 index

pub fn check(&self, now: u64) -> bool

检查是否应该做一次滚动 - 内部使用

• now 当前线程时间 <与创建时设置的 now 属于同一时间进度>

pub fn roll_once(&mut self)

滚动一次 - 使用者不调用

pub fn get_item_timeout(&self, item: &TimeoutItem<T>) -> u64

Trait Implementations

impl<T, const N1: usize, const N2: usize, const N3: usize, const N4: usize> Debug for LocalTimer<T, N1, N2, N3, N4>

where T: Debug,

fn fmt(&self, fmt: &mut Formatter<'_>) -> FResult

Formats the value using the given formatter.