7 releases (breaking)
0.7.0 | Jul 15, 2023 |
---|---|
0.6.0 | Mar 21, 2021 |
0.5.0 | Mar 12, 2021 |
0.4.0 | Mar 11, 2021 |
0.1.0 | Mar 11, 2021 |
#1195 in Asynchronous
20,180 downloads per month
Used in 2 crates
11KB
168 lines
awaitgroup
A WaitGroup
waits for a collection of async tasks to finish.
The main task can create new workers and pass them to each of the tasks it wants to wait for. Each of the tasks calls done
when
it finishes executing, and the main task can call wait
to block until all registered workers are done.
use awaitgroup::WaitGroup;
#[tokio::main]
async fn main() {
let mut wg = WaitGroup::new();
for _ in 0..5 {
// Create a new worker.
let worker = wg.worker();
tokio::spawn(async {
// Do some work...
// This task is done all of its work.
worker.done();
});
}
// Block until all other tasks have finished their work.
wg.wait().await;
}
See the documentation for more details.