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;
3 Jan 4, 2023
12 Jan 21, 2023
22 Jan 7, 2023
4 Feb 9, 2023
4 May 20, 2023
10 Dec 10, 2021
30 Aug 24, 2022
169 Jan 8, 2023
6 Dec 22, 2021
34 Apr 17, 2023
229 Nov 27, 2022
293 Dec 26, 2022
7.6k Dec 31, 2022
189 Dec 25, 2022
11 Jun 3, 2021
2.4k Jan 6, 2023
3.5k Jan 6, 2023
13 Aug 23, 2022
73 Dec 26, 2022