Struct tarantool_module::fiber::Cond

pub struct Cond { /* fields omitted */ }

Conditional variable for cooperative multitasking (fibers).

A cond (short for "condition variable") is a synchronization primitive that allow fibers to yield until some predicate is satisfied. Fiber conditions have two basic operations - wait() and signal(). wait() suspends execution of fiber (i.e. yields) until signal() is called.

Unlike pthread_cond, fiber_cond doesn't require mutex/latch wrapping.

Implementations

impl Cond

pub fn new() -> Self

Instantiate a new fiber cond object.

pub fn signal(&self)

Wake one fiber waiting for the cond. Does nothing if no one is waiting.

pub fn broadcast(&self)

Wake up all fibers waiting for the cond.

pub fn wait_timeout(&self, timeout: f64) -> bool

Suspend the execution of the current fiber (i.e. yield) until signal() is called.

Like pthread_cond, FiberCond can issue spurious wake ups caused by explicit Fiber::wakeup() or Fiber::cancel() calls. It is highly recommended to wrap calls to this function into a loop and check an actual predicate and fiber_testcancel() on every iteration.

• timeout - timeout in seconds

Returns:

• true on signal() call or a spurious wake up.
• false on timeout, diag is set to TimedOut

pub fn wait(&self) -> bool

Shortcut for wait_timeout().

Trait Implementations

impl Drop for Cond

fn drop(&mut self)

Executes the destructor for this type.