Struct WorkerQueue 

pub struct WorkerQueue { /* private fields */ }

Per-worker task queue supporting work-stealing

Implementations

impl WorkerQueue

pub fn new(worker_id: WorkerId) -> Self

Create a new worker queue

pub fn push(&self, task: WorkStealingTask)

Push a task to the local queue

pub fn pop(&self) -> Option<WorkStealingTask>

Pop a task from the local queue (highest priority first)

pub fn steal(&self) -> Option<WorkStealingTask>

Steal a task from this queue (lowest priority - be nice to owner)

pub fn is_empty(&self) -> bool

Check if queue is empty

pub fn len(&self) -> usize

Get queue length

pub fn mark_completed(&self)

Mark a task as completed

pub fn worker_id(&self) -> WorkerId

Get worker ID

pub fn completed_count(&self) -> u64

Get completed count

pub fn stolen_count(&self) -> u64

Get stolen count

Trait Implementations

impl Debug for WorkerQueue

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

Formats the value using the given formatter.