Struct multiqueue::wait::YieldingWait

pub struct YieldingWait { /* fields omitted */ }

This spins on the queue for a few iterations and then starts yielding intermittently

Implementations

impl YieldingWait

pub fn new() -> YieldingWait

Calls with_spins(DEFAULT_TRY_SPINS, DEFAULT_YIELD_SPINS)

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

Constructs a YieldingWait that busywaits for spins_first spins and then yields every spins_yield spins.

Trait Implementations

impl Clone for YieldingWait

fn clone(&self) -> YieldingWait

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Wait for YieldingWait

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

fn notify(&self)

Called by writers to awaken waiting readers

fn needs_notify(&self) -> bool

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

impl Copy for YieldingWait

impl Send for YieldingWait

impl Sync for YieldingWait