方法一:使用带有缓冲的channel 的特性
- 直到缓冲区被填满后,写端才会阻塞。
- 缓冲区被读空,读端才会阻塞。
package main
import "fmt"
func main() {
loopMax := 100
limitGrouting := 10
ch := make(chan struct{}, limitGrouting)
defer close(ch)
for i := 0; i < loopMax; i++ {
go func(a int) {
fmt.Println("hello ", a)
ch <- struct{}{}
}(i)
}
for i := 0; i < loopMax; i++ {
<-ch
}
}
代码中channel数据结构为什么定义struct ?
因为空结构体变量的内存占用大小为0,而bool类型内存占用大小为1,这样可以更加最大化利用我们服务器的内存空间。
方法二:使用sync.WaitGroup
WaitGroup 对象内部有一个计数器,最初从0开始,它有三个方法:Add(), Done(), Wait() 用来控制计数器的数量。
package main
import (
"fmt"
"sync"
)
func main() {
limitGrouting := 10
wg := sync.WaitGroup{}
for i := 0; i < limitGrouting; i++ {
wg.Add(1)
go func(a int) {
fmt.Println("hello ", a)
wg.Done()
}(i)
}
wg.Wait()
}
网友评论