Struct AsyncQueue 

pub struct AsyncQueue { /* private fields */ }

A simple async-style task queue that stores pending and completed tasks.

Implementations

impl AsyncQueue

pub fn new(max_concurrent: usize) -> Self

pub fn enqueue(&mut self, id: u64, label: &str) -> bool

pub fn pending_count(&self) -> usize

pub fn completed_count(&self) -> usize

pub fn total_count(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn running_count(&self) -> usize

pub fn can_start_more(&self) -> bool

pub fn start_next(&mut self) -> Option<u64>

pub fn complete_task(&mut self, id: u64) -> bool

pub fn fail_task(&mut self, id: u64) -> bool

pub fn set_progress(&mut self, id: u64, progress: f32) -> bool

pub fn clear_completed(&mut self)

pub fn get_task(&self, id: u64) -> Option<&AsyncTask>

pub fn failed_count(&self) -> usize

pub fn max_concurrent(&self) -> usize

Trait Implementations

impl Clone for AsyncQueue

fn clone(&self) -> AsyncQueue

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AsyncQueue

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

Formats the value using the given formatter.