Struct LockFreeOptQueueU16 

pub struct LockFreeOptQueueU16<T, const N: usize> { /* private fields */ }

Available on crate feature queue only.

Implementation of an Atomic queue

Implementations

impl<T, const N: usize> LockFreeOptQueueU16<T, N>

pub fn try_pull_id(&self, id: u16) -> Option<T>

Try to pull an item from the queue. The item need to be in the queue otherwise it will not try.

pub unsafe fn push(&self, val: T) -> Result<(u16, u16), QueueError<T>>

Push an item in the queue. Return the id of the element in the queue, or an error if it can’t push the item

Safety

• Only one thread can push into the queue otherwise the queue may block.

pub fn try_pull(&self) -> Result<Option<T>, QueueError<T>>

Try to pull an item from the queue.

pub fn pull(&self) -> Result<T, QueueError<T>>

Pull an item from the queue.

Trait Implementations

impl<T, const N: usize> Debug for LockFreeOptQueueU16<T, N>

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

Formats the value using the given formatter.

impl<T, const N: usize> Default for LockFreeOptQueueU16<T, N>

fn default() -> Self

Returns the “default value” for a type.

impl<T, const N: usize> Drop for LockFreeOptQueueU16<T, N>

fn drop(&mut self)

Executes the destructor for this type.

impl<T, const N: usize> QueueChecker<u16> for LockFreeOptQueueU16<T, N>

fn is_empty(&self) -> bool

Checks if the queue is empty. Prefer this method over len() != 0

fn is_full(&self) -> bool

Checks if the queue is full. Prefer this method over len() != max_capacity()

fn len(&self) -> u16

Returns the number of item in the queue.

fn max_capacity(&self) -> u16

Returns the maximum item capacity of the queue.