waitgroup example

gistfile1.txt

Title: Waiting for goroutines to finish
URL slug: waitgroup
Description: A WaitGroup provides a simple way to wait for a collection of goroutines to perform a task.

gistfile2.txt

package main

import (
	"fmt"
	"math/rand"
	"sync"
	"time"
)

// Important to pass wg by pointer
func worker(id int, wg *sync.WaitGroup) {
	fmt.Printf("Worker %d starting\n", id)
	time.Sleep(time.Duration(500+rand.Intn(500)) * time.Millisecond)
	fmt.Printf("Worker %d done\n", id)

	wg.Done()
}

func main() {
	var wg sync.WaitGroup

	for i := 1; i <= 10; i++ {
		wg.Add(1)
		go worker(i, &wg)
	}

	wg.Wait()
	// All workers are done here.
}