go语言中控制并发数量的方法

MO_ON_e503 · · 787 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

因为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; 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是可以去掉的,例子里用只是为了防止主程序退出之后,没有全部输出,正常工作中,程序一般都是阻塞式的,所以可以去掉。

本文来自php中文网的golang教程栏目:https://www.php.cn/be/go/


有疑问加站长微信联系(非本文作者)

本文来自:简书

感谢作者:MO_ON_e503

查看原文:go语言中控制并发数量的方法

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

787 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传