Skip to content

Latest commit

 

History

History
36 lines (26 loc) · 1.15 KB

README.md

File metadata and controls

36 lines (26 loc) · 1.15 KB

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.