Struct Cond 

pub struct Cond { /* private fields */ }

A goroutine-aware condition variable.

Like std::sync::Condvar but parks goroutines instead of OS threads, so other goroutines sharing the same M continue to be scheduled while waiters sleep.

Must be used from within a [go_lib::run] context.

Implementations

impl Cond

pub fn new() -> Self

Create a new Cond.

pub fn wait<'a, T>( &self, mu: &'a Mutex<T>, guard: MutexGuard<'a, T>, ) -> MutexGuard<'a, T>

Release guard, park the current goroutine until notified, then re-acquire the mutex and return the new guard.

Spurious wakeups are possible; always re-check the predicate in a loop:

let mut guard = mu.lock().unwrap();
while !*guard {
    guard = cnd.wait(&mu, guard);
}

Panics

Panics if called from outside a goroutine context (i.e. before run()).

pub fn notify_one(&self)

Wake one waiting goroutine. No-op if there are no waiters.

pub fn notify_all(&self)

Wake all waiting goroutines.

Trait Implementations

impl Default for Cond

fn default() -> Self

Returns the “default value” for a type.

impl Send for Cond

impl Sync for Cond