simple-go-workers.go

package main

import (
        "fmt"
        "log"
        "sync"
        "time"
)

func main() {
        wg := &sync.WaitGroup{}
        c := make(chan string)
        wg.Add(10)
        for i := 1; i <= 10; i++ {
                go func(ind int, ch <-chan string) {
                        for v := range c {
                                time.Sleep(time.Millisecond)
                                log.Printf("Goroutine %d: %s", ind, v)
                        }
                        wg.Done()
                }(i, c)
        }
        for i := 0; i < 20000; i++ {
                c <- fmt.Sprintf("value %d", i)
        }
        close(c)
        wg.Wait()
}