ゴルーチンをプールするパターン

gistfile1.go

package main

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

func main() {
	pool := make(chan bool, 3)
	job := make(chan string)

	go func() {
		for {
			fmt.Println(<-job)
		}
	}()

	var wg sync.WaitGroup

	for i := 0; i < 10; i++ {
		pool <- true
		wg.Add(1)
		go func(i int) {
			defer func() { <-pool }()
			job <- fmt.Sprintf("start job #%d", i)
			time.Sleep(time.Second)
			job <- fmt.Sprintf("end job #%d", i)
			wg.Done()
		}(i)
	}

	wg.Wait()

}

こんなかんじ

まちがってた