Struct WorkQueue 

pub struct WorkQueue<T: Clone> {
    pub items: VecDeque<WorkItem<T>>,
    pub processed_count: usize,
    pub total_time: Duration,
    pub avg_time: Duration,
}

Work queue for a single worker thread

Fields

items: VecDeque<WorkItem<T>>

Double-ended queue for work items

processed_count: usize

Number of items processed by this worker

total_time: Duration

Total execution time for this worker

avg_time: Duration

Average execution time per item

Implementations

impl<T: Clone> WorkQueue<T>

pub fn push_front(&mut self, item: WorkItem<T>)

Add work item to the front of the queue (for local work)

pub fn push_back(&mut self, item: WorkItem<T>)

Add work item to the back of the queue (for stolen work)

pub fn pop_front(&mut self) -> Option<WorkItem<T>>

Take work from the front (local work)

pub fn steal_back(&mut self) -> Option<WorkItem<T>>

Steal work from the back (work stealing)

pub fn update_timing(&mut self, executiontime: Duration)

Update timing statistics

pub fn estimated_load(&self) -> Duration

Get the current load (estimated remaining work time)

Trait Implementations

impl<T: Debug + Clone> Debug for WorkQueue<T>

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

Formats the value using the given formatter.

impl<T: Clone> Default for WorkQueue<T>

fn default() -> Self

Returns the “default value” for a type.