Struct WorkStealQueue 

pub struct WorkStealQueue<T: Marshal + Copy + 'static> { /* private fields */ }

Single-owner, multi-thief work-stealing queue, backed by the SharedDeque<T> family. The owner pushes via push; thieves drain via steal.

The dispatcher’s variant pick for the caller’s workload shape is reported via variant; the generic-T: Marshal surface uses Chase-Lev as the backing because it is the only variant generic over arbitrary T: Marshal. Byte-slice workloads (e.g. scheduler PassSlot) can ride the higher- throughput KHL/KHPD/LOH/URD variants directly via the DequeDispatcher API.

Implementations

impl<T: Marshal + Copy + 'static> WorkStealQueue<T>

pub fn create( path: impl AsRef<Path>, shape: MmfWorkloadShape, capacity: usize, ) -> Result<Self, ApiError>

Create the queue at path with the given workload shape. capacity is rounded up to next pow2.

pub fn open_as_thief(path: impl AsRef<Path>) -> Result<Self, ApiError>

Open an existing queue at path as a thief.

pub fn push(&self, item: &T) -> Result<(), ApiError>

Owner-side push.

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

Owner-side pop (LIFO end).

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

Thief-side steal (FIFO end).

pub fn variant(&self) -> DequeVariant

The variant the dispatcher picked for this workload.