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()
}

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

还有其他实现方式,比如利用原子包,互斥锁等,大家可以多去试试

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • Chapter 8 Goroutines and Channels Go enable two styles of...
    SongLiang阅读 1,641评论 0 3
  • 本篇文章是我对 Go 语言并发性的理解总结,适合初步了解并发,对 Go 语言的并发编程与调度器原理有兴趣的读者。 ...
    baiyi阅读 1,270评论 0 4
  • 2018年3月1日,星期五,晴。(柔者处上之大学历练——连载第286篇) 三月的第一天,天气倒是比前几天冷了一些。...
    枫郁樰阅读 217评论 0 1
  • 当一个想要自杀的人找你咨询,你能制止他的自杀吗? 一个人不能唤不醒一个装睡的人; 一个人帮不了一个决定要离婚的人,...
    方圆fg阅读 1,058评论 0 3
  • 01 我不知道有没有人和我一样,生活中很少走好运。当然,这也不是说我就天天在倒霉,只是说很少有意外惊喜。付出十分努...
    迅图阅读 2,826评论 0 4