Struct EventQueue 

pub struct EventQueue {
    arena: Vec<EventNode>,
    arena_used: u32,
    free_head: u32,
    wheel_head: Vec<u32>,
    wheel_tail: Vec<u32>,
    slot_bitmap: [u64; 512],
    current_slot: usize,
    current_time_ms: u32,
    wheel_base_ms: u32,
    overflow: Vec<OverflowEntry>,
    next_seq: u64,
    count: usize,
}

Priority event queue using a timing wheel with arena-allocated linked lists.

Fields

arena: Vec<EventNode>

arena_used: u32

free_head: u32

wheel_head: Vec<u32>

wheel_tail: Vec<u32>

slot_bitmap: [u64; 512]

current_slot: usize

current_time_ms: u32

wheel_base_ms: u32

overflow: Vec<OverflowEntry>

next_seq: u64

count: usize

Implementations

impl EventQueue

pub(super) fn insert_into_wheel(&mut self, time_ms: u32, seq: u64, event: Event)

pub(super) fn rotate_wheel_base(&mut self)

pub(super) fn pop_from_slot(&mut self, slot: usize, head_idx: u32) -> Event

pub(super) fn set_slot_bit(&mut self, slot: usize)

pub(super) fn clear_slot_bit(&mut self, slot: usize)

pub(super) fn find_next_slot(&self) -> Option<usize>

pub(super) fn alloc_node(&mut self, time_ms: u32, seq: u64, event: Event) -> u32

pub(super) fn free_node(&mut self, idx: u32)

impl EventQueue

pub fn new() -> Self

Construct an empty queue with the default arena capacity.

pub fn with_capacity(capacity: usize) -> Self

Construct an empty queue, pre-sizing the arena to at least capacity nodes.

pub fn push(&mut self, event: Event)

Push an event onto the queue.

Panics

Panics if the event precedes the last event popped from this queue.

pub fn pop(&mut self) -> Option<Event>

Pop the highest-priority event (smallest timestamp, priority, then sequence).

pub fn clear(&mut self)

Reset to empty without deallocating; keeps arena/wheel capacity.

pub fn is_empty(&self) -> bool

true iff no events are pending in either the wheel or the overflow bucket.

pub fn len(&self) -> usize

Number of events currently queued, including those in the overflow bucket.

Trait Implementations

impl Debug for EventQueue

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

Formats the value using the given formatter.

impl Default for EventQueue

fn default() -> Self

Returns the “default value” for a type.