Struct TaskQueue 

pub struct TaskQueue { /* private fields */ }

Task queue with priority support.

Implementations

impl TaskQueue

pub fn new() -> Self

Create a new task queue.

pub fn with_max_size(max_size: usize) -> Self

Create a new task queue with maximum size.

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

Enqueue a task.

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

Dequeue the highest priority task.

pub async fn try_dequeue(&self) -> Option<Task>

Try to dequeue without blocking.

pub async fn complete(&self, task_id: TaskId, success: bool)

Complete a task.

pub fn get_task(&self, task_id: &TaskId) -> Option<Task>

Get task by ID.

pub fn get_running_task(&self, task_id: &TaskId) -> Option<Task>

Get running task by ID.

pub async fn len(&self) -> usize

Get queue length (pending + running).

pub async fn is_empty(&self) -> bool

Check if queue is empty.

pub async fn pending_count(&self) -> usize

Get number of pending tasks.

pub fn running_count(&self) -> usize

Get number of running tasks.

pub async fn clear(&self)

Clear all tasks.

pub async fn get_pending_tasks(&self) -> Vec<Task>

Get all pending tasks (for inspection).

pub fn get_running_tasks(&self) -> Vec<Task>

Get all running tasks (for inspection).

pub async fn remove(&self, task_id: TaskId) -> bool

Remove a task from the queue (if not running).

pub async fn requeue(&self, task: Task) -> Result<()>

Requeue a failed task for retry.

pub async fn statistics(&self) -> QueueStatistics

Get queue statistics.

Trait Implementations

impl Clone for TaskQueue

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for TaskQueue

fn default() -> Self

Returns the “default value” for a type.