Struct TaskQueue 

pub struct TaskQueue { /* private fields */ }

Thread-safe task queue with priority support

Implementations

impl TaskQueue

pub fn new(max_size: usize) -> Self

Create a new task queue

pub async fn enqueue(&self, task: Task, priority: TaskPriority) -> Result<()>

Add a task to the queue

pub async fn dequeue(&self) -> Option<QueuedTask>

Dequeue the highest priority task

pub async fn dequeue_and_assign(&self, worker_id: String) -> Option<QueuedTask>

Dequeue a task and assign it to a worker

pub async fn peek(&self) -> Option<QueuedTask>

Peek at the next task without removing it

pub async fn size(&self) -> usize

Get the total number of tasks in the queue

pub async fn size_by_priority(&self) -> (usize, usize, usize, usize)

Get the number of tasks at each priority level

pub async fn is_empty(&self) -> bool

Check if the queue is empty

pub async fn is_full(&self) -> bool

Check if the queue is full

pub async fn clear(&self)

Clear all tasks from the queue

pub async fn all_tasks(&self) -> Vec<QueuedTask>

Get all tasks (for inspection/debugging)

pub async fn find_by_status(&self, status: TaskStatus) -> Vec<QueuedTask>

Find tasks by status

pub async fn remove_by_id(&self, task_id: &str) -> Option<QueuedTask>

Remove a specific task by ID

Trait Implementations

impl Default for TaskQueue

fn default() -> Self

Returns the “default value” for a type.