Struct WaitGroup

pub struct WaitGroup { /* private fields */ }

A WaitGroup waits for a collection of coroutines to finish.

Examples

use rust_waitgroup::WaitGroup;
use std::thread;

let wg = WaitGroup::default();
let n = 10;
for _ in 0..n {
   let wg = wg.clone();
   wg.add(1);
   thread::spawn(move || {
        // do some work
        wg.done();
   });
}
wg.wait();

Implementations

impl WaitGroup

pub fn new() -> Self

pub fn add(&self, delta: i64)

add adds delta, which may be negative, to the WaitGroup counter. if the counter becomes zero, all coroutines blocked on Wait are released. if the counter goes negative, add panics

pub fn done(&self)

done decrements the WaitGroup counter by one.

pub fn wait(&self)

wait blocks until the WaitGroup counter is zero.

Trait Implementations

impl Clone for WaitGroup

fn clone(&self) -> WaitGroup

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for WaitGroup

fn default() -> Self

Returns the “default value” for a type.