Struct multiqueue2::wait::BlockingWait

pub struct BlockingWait { /* fields omitted */ }

This tries spinning on the queue for a short while, then yielding, and then blocks

Implementations

impl BlockingWait

pub fn new() -> BlockingWait

Calls with_spins(DEFAULT_TRY_SPINS, DEFAULT_YIELD_SPINS)

pub fn with_spins(spins_first: usize, spins_yield: usize) -> BlockingWait

Constructs a YieldingWait that busywaits for spins_first spins and then yields for spins_yield spins, then blocks on a condition variable.

Trait Implementations

impl Clone for BlockingWait

pub fn clone(&self) -> BlockingWait

Returns a copy of the value.

pub fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for BlockingWait

pub fn default() -> BlockingWait

Returns the "default value" for a type.

impl Send for BlockingWait

impl Sync for BlockingWait

impl Wait for BlockingWait

pub fn wait(&self, seq: usize, w_pos: &AtomicUsize, wc: &AtomicUsize)

Causes the reader to block until the queue is available. Is passed the queue tag which the readers are waiting on, a reference to the corresponding AtomicUsize, and a reference to the number of writers

pub fn notify(&self)

Called by writers to awaken waiting readers

pub fn needs_notify(&self) -> bool

Returns whether writers need to call notify Optimized the various BusyWait variants