Struct WorkQueue 

pub struct WorkQueue {
    pub deque: Vec<StealableTask>,
    pub owner_id: u32,
}

A double-ended work queue owned by a single worker.

The owner pushes and pops from the back (LIFO); thieves steal from the front (FIFO) to minimise cache invalidation.

Fields

deque: Vec<StealableTask>

The internal deque of tasks (front = steal end, back = owner end).

owner_id: u32

Identifier of the owning worker.

Implementations

impl WorkQueue

pub fn new(owner_id: u32) -> Self

Create a new empty work queue for the given owner.

pub fn push(&mut self, task: StealableTask)

Push a task onto the owner’s end of the queue (back).

pub fn pop(&mut self) -> Option<StealableTask>

Pop a task from the owner’s end of the queue (back, LIFO).

Returns None if the queue is empty.

pub fn steal(&mut self) -> Option<StealableTask>

Steal a task from the thief’s end of the queue (front, FIFO).

Returns None if the queue is empty.

pub fn len(&self) -> usize

Returns the number of tasks in the queue.

pub fn is_empty(&self) -> bool

Returns true if the queue has no tasks.

pub fn high_priority_tasks(&self) -> Vec<&StealableTask>

Returns all high-priority tasks (without removing them).

Trait Implementations

impl Debug for WorkQueue

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

Formats the value using the given formatter.