Struct TaskQueue 

pub struct TaskQueue { /* private fields */ }

Task queue with priority support

Implementations

impl TaskQueue

pub fn new() -> Self

pub fn enqueue(&mut self, task: DistributedTask) -> CoreResult<()>

pub fn dequeue_next(&mut self) -> Option<DistributedTask>

pub fn dequeue_highest_priority(&mut self) -> Option<DistributedTask>

pub fn size(&self) -> usize

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.