Struct TaskPriorityQueue 

pub struct TaskPriorityQueue { /* private fields */ }

A priority queue for scheduling workflow tasks.

Implementations

impl TaskPriorityQueue

pub fn new() -> Self

Create a new empty priority queue.

pub fn with_aging_threshold(self, secs: u64) -> Self

Set the aging threshold (seconds of waiting before priority promotion).

pub fn enqueue( &mut self, task_id: impl Into<String>, priority: PriorityLevel, submitted_secs: u64, ) -> u64

Enqueue a task with the given priority and submission time.

pub fn enqueue_with_deadline( &mut self, task_id: impl Into<String>, priority: PriorityLevel, submitted_secs: u64, deadline_secs: u64, ) -> u64

Enqueue a task with a deadline.

pub fn dequeue(&mut self) -> Option<PriorityEntry>

Dequeue the highest-priority task.

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

Peek at the highest-priority task without removing it.

pub fn len(&self) -> usize

Return the number of enqueued tasks.

pub fn is_empty(&self) -> bool

Check if the queue is empty.

pub fn apply_aging(&mut self, now_secs: u64)

Apply priority aging: promote tasks that have been waiting longer than the threshold.

This drains and rebuilds the heap, so call sparingly.

pub fn drain_overdue(&mut self, now_secs: u64) -> Vec<PriorityEntry>

Drain all overdue tasks (past their deadline).

pub fn clear(&mut self)

Clear all tasks from the queue.

pub fn count_by_priority(&self) -> [usize; 4]

Count tasks at each priority level.

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.