Struct PriorityTaskQueue 

pub struct PriorityTaskQueue { /* private fields */ }

A bounded multi-priority task queue.

Tasks with Priority::High are dequeued before Priority::Normal, which are dequeued before Priority::Low. Within a priority level tasks are served FIFO.

Implementations

impl PriorityTaskQueue

pub fn new(capacity: usize) -> Self

Create a queue that holds at most capacity pending tasks.

pub fn submit<F>(&self, priority: Priority, f: F) -> CoreResult<()>

where F: FnOnce() + Send + 'static,

Submit a task at the given priority.

Blocks if the queue is at capacity, or returns Err if the queue is closed.

pub fn try_submit<F>(&self, priority: Priority, f: F) -> CoreResult<()>

where F: FnOnce() + Send + 'static,

Try to submit without blocking. Returns Err if full or closed.

pub fn dequeue(&self) -> CoreResult<Option<Box<dyn FnOnce() + Send + 'static>>>

Block until a task is available, then return it.

Returns None when the queue is closed and drained.

pub fn try_dequeue( &self, ) -> CoreResult<Option<Box<dyn FnOnce() + Send + 'static>>>

Try to dequeue without blocking. Returns None if empty.

pub fn close(&self)

Close the queue. Pending tasks may still be dequeued; new submits fail.

pub fn pending(&self) -> usize

Number of pending tasks.