Struct TimerScheduler

pub struct TimerScheduler {
    pub(crate) queue: BinaryHeap<ScheduledEvent>,
}

A queue of TimerEventRequests that are stored in order of next-to-fire.

Fields

queue: BinaryHeap<ScheduledEvent>

A priority queue of future events, sorted by due time.

Implementations

impl TimerScheduler

pub fn schedule_timer(&mut self, request: TimerEventRequest)

Schedule a new timer for on this TimerScheduler.

pub fn wait_channel(&self) -> Receiver<Instant>

Get a Receiver<Instant> that receives a message after waiting for the next timer to fire. If there are no timers, the channel will never send a message.

pub fn dispatch_completed_timers(&mut self)

Dispatch any timer events from this TimerScheduler’s queue when now is past the due time of the event.

Trait Implementations

impl Default for TimerScheduler

fn default() -> TimerScheduler

Returns the “default value” for a type.

impl MallocSizeOf for TimerScheduler

fn size_of(&self, ops: &mut MallocSizeOfOps) -> usize

Measure the heap usage of all descendant heap-allocated structures, but not the space taken up by the value itself.