GO语言里面怎么控制并发数量,方法是什么?
导读:在这篇文章中我们会学习到关于“GO语言里面怎么控制并发数量,方法是什么?”的知识,小编觉得挺不错的,现在分享给大家,也给大家做个参考,希望对大家学习或工作能有帮助。下面就请大家跟着小编的思路一起来学习一下吧。 因为g...
在这篇文章中我们会学习到关于“GO语言里面怎么控制并发数量,方法是什么?”的知识,小编觉得挺不错的,现在分享给大家,也给大家做个参考,希望对大家学习或工作能有帮助。下面就请大家跟着小编的思路一起来学习一下吧。因为go语言层面支持并发,所以面试中经常会问到并发的问题,比如说控制go并发数量的方式有哪些?下面是我个人整理的两个例子:
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() // 也可使用 wg.Add(-1) } (i) } wg.Wait() }
上面主要用到的是go中sync包下的waitGroup,这也是在工作中比较常见的实现方式,关键点就是把握好Add方法的位置,Wait方法则是等待所有的协程执行完毕
func channel() { count := 10 // 最大支持并发 sum := 100 // 任务总数 c := make(chan struct{ } , count) // 控制任务并发的chan sc := make(chan struct{ } , sum) // 控制任务总数的chan defer close(c) defer close(sc) for i:=0; isum; i++{ c - struct{ } { } // 作用类似于waitgroup.Add(1) 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语言里面怎么控制并发数量,方法是什么?的介绍啦,需要的朋友可以参考上述内容,希望对大家有帮助,欢迎关注网络,小编将为大家输出更多高质量的实用文章!
声明:本文内容由网友自发贡献,本站不承担相应法律责任。对本内容有异议或投诉,请联系2913721942#qq.com核实处理,我们将尽快回复您,谢谢合作!
若转载请注明出处: GO语言里面怎么控制并发数量,方法是什么?
本文地址: https://pptw.com/jishu/653935.html