Struct Queue 

pub struct Queue { /* private fields */ }

A timer queue, with items integrated into tasks.

Safety

This Queue is only safe when there is a single integrated queue in the system.

If there are multiple integrated queues, additional checks are necessary to ensure that a Waker is not attempted to be enqueued in multiple queues.

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.

Trait Implementations

impl Debug for Queue

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

Formats the value using the given formatter.

impl Send for Queue

impl Sync for Queue