[go routine pool] #go

main.go

// simple go routine pool
package main

import (
	"sync"
)

func main() {

	var wg sync.WaitGroup

	var routineNumber int
	// var routineNumber int = 1000

	// init go routine pool
  pool := make(chan struct{}, routineNumber)

	for {
      pool <- struct{}{}
		wg.Add(1)
		go do(pool, &wg)
	}

	wg.Wait()
}

func do(pool chan int, wg *sync.WaitGroup) {
	defer func() {
		<- pool
		wg.Done()
	}()

	// do something
}