WAG

Go like sync.WaitGroup implementation in Rust. (sync/async)

| Examples | Docs | Latest Note |

wag = "0.3.0"

How to use,

use wag::WaitGroup;

let wg = WaitGroup::new();

for _ in 0..10 {
    let w = wg.add();

    thread::spawn(move || {
        // ...
        w.done();
    });

});
wg.wait(); // or wg.async_wait().await;

for w in wg.adds::<10>() {

    thread::spawn(move || {
        // ...
        w.done();
    });

});
wg.wait(); // or wg.async_wait().await;

let [w1, w2, w3] = wg.adds();

thread::spawn(move || {
    // ...
    w1.done();
});

thread::spawn(move || {
    // ...
    w2.done();
});

thread::spawn(move || {
    // ...
    w3.done();
});

wg.wait(); // or wg.async_wait().await;

wg.adds_iter::<10>().enumerate().for_each(|(i, w)| {

    thread::spawn(move || {
        // ... with i
        w.done();
    });

});
wg.wait(); // or wg.async_wait().await;