golang async worker example

main.go

package main

import (
	"fmt"
	"time"
)

func main() {
	task := make(chan string)
	taskquit := make(chan bool)
	workerquit := make(chan bool)

	parallel := 3

	for i := 0; i < parallel; i++ {
		go func() {
		loop:
			for {
				select {
				case <-taskquit:
					workerquit <- true
					break loop
				case job := <-task:
					fmt.Println(job)
					time.Sleep(1 * time.Second)
				}
			}
		}()
	}

	go func() {
		for n := 0; n < 7; n++ {
			task <- fmt.Sprintf("お仕事%03d", n+1)
		}
		for {
			if len(task) == 0 {
				for i := 0; i < parallel; i++ {
					taskquit <- true
				}
			}
			time.Sleep(200 * time.Millisecond)
		}
	}()
	for i := 0; i < parallel; i++ {
		<-workerquit
	}

}