本文摘自php中文网,作者尚,侵删。
因为go语言层面支持并发,所以面试中经常会问到并发的问题,比如说控制go并发数量的方式有哪些?下面是我个人整理的两个例子:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 | func waitGroup() {
count := 10
wg := sync.WaitGroup{}
for i := 0; i < count ; i++ {
wg.Add(1)
go func(j int) {
fmt. Print (j)
wg.Done()
}(i)
}
wg.Wait()
}
|
上面主要用到的是go中sync包下的waitGroup,这也是在工作中比较常见的实现方式,关键点就是把握好Add方法的位置,Wait方法则是等待所有的协程执行完毕
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 | func channel() {
count := 10
sum := 100
c := make(chan struct{}, count )
sc := make(chan struct{}, sum)
defer close(c)
defer close(sc)
for i:=0; i<sum;i++{
c <- struct{}{}
go func(j int) {
fmt.Println(j)
<- c
sc <- struct {}{}
}(i)
}
for i:=sum; i>0;i-- {
<- sc
}
}
|
上面的例子用到的是go中的channel,利用channel阻塞的特性和带缓冲的channel来实现控制并发数量,其中sc这个channel是可以去掉的,例子里用只是为了防止主程序退出之后,没有全部输出,正常工作中,程序一般都是阻塞式的,所以可以去掉。
更多相关知识请关注go语言教程栏目
以上就是go语言中控制并发数量的方法的详细内容,更多文章请关注木庄网络博客!!
相关阅读 >>
Go语言属于什么语言
Go语言进行数组比较的方法是什么
Go语言中包导入的一些问题
什么是Go语言?Go语言的优缺点介绍
Go语言中处理json数据的方法
go是动态语言吗
Go语言有指针吗
Go语言 类型转换表示什么
Go语言和python的区别是什么?
Go语言的25个关键字介绍
更多相关阅读请进入《Go语言》频道 >>
老貘
一个与时俱进的Go编程知识库。
转载请注明出处:木庄网络博客 » go语言中控制并发数量的方法