Struct WfQueue

pub struct WfQueue { /* private fields */ }

Implementations

impl WfQueue

pub fn new(cap: usize) -> WfQueue

pub fn len(&self) -> usize

pub fn capacity(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn is_full(&self) -> bool

pub fn try_enqueue(&self, ctx: &EnqueueCtx, val: NonZeroUsize) -> bool

Each queue should use a fixed enqueue context in each thread. If the wrong context is used, it may lead to logic confusion.

pub fn try_dequeue(&self, ctx: &DequeueCtx) -> Option<NonZeroUsize>

Each queue should use a fixed enqueue context in each thread. If the wrong context is used, it may lead to logic confusion.