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

Download history 3587/week @ 2024-07-23 3573/week @ 2024-07-30 3509/week @ 2024-08-06 4441/week @ 2024-08-13 3998/week @ 2024-08-20 5311/week @ 2024-08-27 4510/week @ 2024-09-03 4983/week @ 2024-09-10 4542/week @ 2024-09-17 5070/week @ 2024-09-24 3906/week @ 2024-10-01 5004/week @ 2024-10-08 5257/week @ 2024-10-15 5390/week @ 2024-10-22 4736/week @ 2024-10-29 3840/week @ 2024-11-05

20,180 downloads per month
Used in 2 crates

MIT license

11KB
168 lines

awaitgroup

Documentation Version License

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.

No runtime deps