分批执行

main.go

package main

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

const num = 10
func main() {
	pool := make(chan int, num)
	wg := sync.WaitGroup{}
	wg.Add(num)
	send(pool)

	go func() {
		for true {
			wg.Wait()
			send(pool)
			wg.Add(num)
		}
	}()

	for true {
		<-pool
		go func() {
			defer wg.Done()
			job()
		}()
	}

}

func job() {
	fmt.Println(time.Now())
	time.Sleep(time.Second * 2)
}

func send(chan1 chan int)  {
	fmt.Println("send jobs")
	for i:=0; i < num; i++ {
		chan1 <- i
	}
}