Struct Queue

pub struct Queue { /* private fields */ }

A timer queue, with items integrated into tasks.

Implementations

impl Queue

pub const fn new() -> Self

Creates a new timer queue.

pub fn schedule_wake(&mut self, at: u64, waker: &Waker) -> bool

Schedules a task to run at a specific time.

If this function returns true, the called should find the next expiration time and set a new alarm for that time.

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

Dequeues expired timers and returns the next alarm time.

The provided callback will be called for each expired task. Tasks that never expire will be removed, but the callback will not be called.