wg

Golang like WaitGroup implementation for sync/async Rust. [

][Github-url] [

][CI-url] [

][codecov-url] [

][doc-url] [

][crates-url] [

][rustc-url] [

][license-apache-url] [

][license-mit-url]

Installation

toml [dependencies] wg = "0.1.0"

Example

Sync

```rust use wg::WaitGroup; use std::sync::Arc; use std::sync::atomic::{AtomicUsize, Ordering}; use std::time::Duration; use std::thread::{spawn, sleep};

fn main() { let wg = WaitGroup::new(); let ctr = Arc::new(AtomicUsize::new(0));

for _ in 0..5 {
    let ctrx = ctr.clone();
    let t_wg = wg.add(1);
    spawn(move || {
        // mock some time consuming task
        sleep(Duration::from_millis(50));
        ctrx.fetch_add(1, Ordering::Relaxed);

        // mock task is finished
        t_wg.done();
    });
}

wg.wait();
assert_eq!(ctr.load(Ordering::Relaxed), 5);

} ```

Async

```rust use wg::AsyncWaitGroup; use std::sync::Arc; use std::sync::atomic::{AtomicUsize, Ordering}; use tokio::{spawn, time::{sleep, Duration}};

[tokio::main(flavor = "multithread", workerthreads = 10)]

async fn main() { let wg = AsyncWaitGroup::new(); let ctr = Arc::new(AtomicUsize::new(0));

for _ in 0..5 {
    let ctrx = ctr.clone();
    let t_wg = wg.add(1);
    spawn(async move {
        // mock some time consuming task
        sleep(Duration::from_millis(50)).await;
        ctrx.fetch_add(1, Ordering::Relaxed);

        // mock task is finished
        t_wg.done();
    });
}

wg.wait().await;
assert_eq!(ctr.load(Ordering::Relaxed), 5);

} ```

Acknowledgements

Inspired by Golang sync.WaitGroup, [ibraheemdev's AwaitGroup] and [crossbeam_utils::WaitGroup].

License

^{Licensed under either of Apache License, Version
2.0 or MIT license at your option.}

_{Unless you explicitly state otherwise, any contribution intentionally submitted
for inclusion in this project by you, as defined in the Apache-2.0 license,
shall be dual licensed as above, without any additional terms or conditions.}