Struct atomic_try_update::claim::WriteOrderingQueue

pub struct WriteOrderingQueue<T>
where
    T: Send + Countable,
{ /* private fields */ }

Implementations

impl<T> WriteOrderingQueue<T>

where T: Send + Countable,

This is a multi-producer “claim” queue.

pub fn push(&self, val: T) -> (u64, bool)

This returns the offset of the write, and true iff we have the claim. If we have the claim, we are responsible for calling consume_or_release_claim until we manage to release it.

pub fn consume_or_release_claim(&self) -> (NodeIterator<T>, bool)

This removes everything from the queue. If queue is already empty, it releases the claim and returns false

pub fn get_offset(&self) -> u64

Trait Implementations

impl<T> Default for WriteOrderingQueue<T>

where T: Send + Countable,

fn default() -> WriteOrderingQueue<T>

Returns the “default value” for a type.