Struct PriorityQueue 

pub struct PriorityQueue { /* private fields */ }

Thread-safe priority queue for fragments

Implementations

impl PriorityQueue

pub fn new() -> Self

Create a new priority queue

pub fn push(&self, fragment: PrioritizedFragment)

Push a fragment onto the queue

pub fn pop(&self) -> Option<PrioritizedFragment>

Pop the highest priority fragment

pub fn peek(&self) -> Option<PrioritizedFragment>

Peek at the highest priority fragment

pub fn len(&self) -> usize

Get queue length

pub fn is_empty(&self) -> bool

Check if queue is empty

pub fn contains(&self, fragment_id: &FragmentId) -> bool

Check if a fragment is already queued

pub fn clear(&self)

Clear the queue

pub fn update_priority(&self, fragment_id: &FragmentId, new_priority: Priority)

Update priority of a fragment

pub fn get_by_priority( &self, min_priority: Priority, ) -> Vec<PrioritizedFragment>

Get all fragments at or above a priority level

Trait Implementations

impl Default for PriorityQueue

fn default() -> Self

Returns the “default value” for a type.