使用 WaitGroup 控制并发

package main

import (
	"fmt"
	"math/rand"
	"sync"
	"time"
)

func main() {
	// 创建一个 100 个空匿名结构的数组
	var times [100]struct{}
	// 创建一个缓冲长度为 3 的 channel
	conccuryChan := make(chan struct{}, 3)
	// wait group
	var wg sync.WaitGroup
	// 循环 times
	for k := range times {
		// push 一个空数组到 channel 中，当
		conccuryChan <- struct{}{}
		// wait group add 1
		wg.Add(1)

		go func(index int) {
			defer func() {
				// 完成后从 channel 取出一个，下一个可以添加 channel
				<-conccuryChan
			}()
			fmt.Println("=>>>>>>>>>> ", index)
			// 模拟随机时长的逻辑
      		time.Sleep(time.Duration((rand.Intn(3) + 1)) * time.Second)
      		// 标记完成一次
			wg.Done()
		}(k)
	}

	close(conccuryChan)
	wg.Wait()
}