Struct TaskQueue 

pub struct TaskQueue { /* private fields */ }

Task queue for managing pending tasks

Implementations

impl TaskQueue

pub fn new() -> Self

Create a new task queue

pub fn with_capacity(max_size: usize) -> Self

Create a new task queue with maximum size

pub fn enqueue(&mut self, task: ExecutionTask) -> SklResult<()>

Add a task to the queue

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

Remove and return the next task from the queue

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

Peek at the next task without removing it

pub fn len(&self) -> usize

Get the number of tasks in the queue

pub fn is_empty(&self) -> bool

Check if the queue is empty

pub fn clear(&mut self)

Clear all tasks from the queue

pub fn tasks(&self) -> &[ExecutionTask]

Get all tasks in the queue

pub fn sort_by_priority(&mut self)

Sort tasks by priority

pub fn filter<F>(&self, predicate: F) -> Vec<&ExecutionTask>

where F: Fn(&ExecutionTask) -> bool,

Filter tasks by predicate

Trait Implementations

impl Debug for TaskQueue

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

Formats the value using the given formatter.

impl Default for TaskQueue

fn default() -> Self

Returns the “default value” for a type.