Struct TaskPriorityQueue 

pub struct TaskPriorityQueue { /* private fields */ }

A priority queue for tasks.

Implementations

impl TaskPriorityQueue

pub fn new() -> Self

Create a new unbounded queue.

pub fn with_capacity(capacity: usize) -> Self

Create a queue with a maximum capacity.

pub fn set_age_bump_amount(&mut self, amount: u32)

Set the aging bump amount.

pub fn push(&mut self, task: PriorityTask) -> bool

Push a task into the queue.

Returns false if the queue is at capacity.

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

Pop the highest-priority task.

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

Peek at the highest-priority task without removing it.

pub fn len(&self) -> usize

Number of tasks in the queue.

pub fn is_empty(&self) -> bool

Whether the queue is empty.

pub fn clear(&mut self)

Clear all tasks.

pub fn apply_aging(&mut self)

Apply aging: bump the priority of all non-critical tasks.

This prevents starvation of low-priority tasks by gradually increasing their effective priority.

pub fn remove_expired(&mut self, now_ms: u64) -> Vec<PriorityTask>

Remove all tasks that have passed their deadline.

now_ms is the current timestamp in milliseconds. Returns the expired tasks.

pub fn drain_priority(&mut self, priority: Priority) -> Vec<PriorityTask>

Drain all tasks with a given priority.

pub fn capacity(&self) -> usize

Get queue capacity (0 = unlimited).

pub fn try_preempt(&mut self, incoming: PriorityTask) -> Option<PriorityTask>

Attempt to preempt (replace) the lowest-priority task if incoming has strictly higher effective weight.

Returns the displaced task if preemption occurred, or None when the queue is not full, the queue is empty, or incoming does not outrank the current minimum.

Preemption is only meaningful when the queue is at capacity; callers should call push directly when capacity has not been reached.

pub fn would_preempt(&self, incoming: &PriorityTask) -> bool

Check whether the given task would preempt the current lowest-priority occupant without actually performing the preemption.

Trait Implementations

impl Debug for TaskPriorityQueue

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

Formats the value using the given formatter.

impl Default for TaskPriorityQueue

fn default() -> Self

Returns the “default value” for a type.