一文带你了解Golang中的WaitGroups

目录
  • 什么是WaitGroups
  • 如何使用WaitGroups
  • 为什么使用WaitGroups而不是channel
  • 需要注意的一件事
  • 总结

什么是WaitGroups

WaitGroups是同步你的goroutines的一种有效方式。想象一下,你和你的家人一起驾车旅行。你的父亲在一个条形商场或快餐店停下来,买些食物和上厕所。你最好想等大家回来后再开车去地平线。WaitGroups帮助你做到这一点。

WaitGroups是通过调用标准库中的sync包来定义的。

var wg sync.WaitGroup

那么,什么是WaitGroup呢?WaitGroup是一个结构,它包含了程序需要等待多少个goroutine的某些信息。它是一个包含你需要等待的goroutines数量的组。

WaitGroups有三个最重要的方法: AddDone和 Wait

  • Add: 添加到你需要等待的goroutines的总量上。
  • Done: 从你需要等待的goroutines总数中减去一个。
  • Wait: 阻止代码继续进行,直到没有更多的goroutines需要等待。

如何使用WaitGroups

让我们来看看一段代码:

package main

import (
    "fmt"
    "sync"
    "time"
)

func main() {
    var wg sync.WaitGroup
    wg.Add(1)

    go func() {
        defer wg.Done()

        fmt.Println(time.Now(), "start")
        time.Sleep(time.Second)
        fmt.Println(time.Now(), "done")
    }()

    wg.Wait()
    fmt.Println(time.Now(), "exiting...")
}

2022-08-21 17:01:54.184744229 +0900 KST m=+0.000021800 start
2022-08-21 17:01:55.184932851 +0900 KST m=+1.000210473 done
2022-08-21 17:01:55.18507731 +0900 KST m=+1.000354912 exiting...

  • 我们首先初始化一个WaitGroup wg的实例。
  • 然后我们在wg中添加1,因为我们要等待一个goroutine完成。
  • 然后我们运行这个goroutine。在goroutine内部,我们对wg.Done()进行延迟调用,以确保我们递减要等待的goroutine的数量。如果我们不这样做,那么代码将永远等待goroutine完成,并将导致死锁。
  • goroutine调用之后,我们要确保阻断代码,直到WaitGroup为空。我们通过调用wg.Wait()来做到这一点。

为什么使用WaitGroups而不是channel

现在我们知道了如何使用WaitGroups,一个自然而然的想法将我们引向这个问题:为什么使用WaitGroups而不是通道?

根据我的经验,有几个原因。

  • WaitGroups往往更直观。当你阅读一段代码时,当你看到一个WaitGroup时,你会立即知道代码在做什么。方法的名称很明确,而且直奔主题。然而,对于通道来说,有时就不是那么清楚了。使用通道是很聪明的,但当你阅读一段复杂的代码时,理解起来会很麻烦。
  • 有的时候,你不需要使用通道。例如,让我们看一下这段代码:
 var wg sync.WaitGroup

  for i := 0; i < 5; i++ {
      wg.Add(1)
      go func() {
          defer wg.Done()

          fmt.Println(time.Now(), "start")
          time.Sleep(time.Second)
          fmt.Println(time.Now(), "done")
      }()
  }

  wg.Wait()
  fmt.Println(time.Now(), "exiting...")

你可以看到,这个goroutine并没有与其他goroutine进行数据交流。如果你的goroutine是一次性的工作,你不需要知道结果,使用WaitGroup是可取的。现在看一下这段代码:

  ch := make(chan int)

  for i := 0; i < 5; i++ {
      go func() {
          randomInt := rand.Intn(10)
          ch <- randomInt
      }()
  }

  for i := 0; i < 5; i++ {
      fmt.Println(<-ch)
  }

这里,goroutine正在向 channel 发送数据。在这些情况下,我们不需要使用WaitGroup,因为这将是多余的。如果接收已经做了足够的阻塞,为什么还要等待goroutine完成?

WaitGroups是专门用来处理等待goroutines的。我觉得通道的主要目的是为了交流数据。你不能用WaitGroup来发送和接收数据,但你可以用一个channel来同步你的goroutines

最后,没有正确的答案。我知道这可能很烦人,但这取决于你和你工作的团队。无论什么方法都是最好的,没有答案是错误的。我个人倾向于使用WaitGroups进行同步,但你的情况可能有所不同。选择对你来说最直观的东西。

需要注意的一件事

有时,你可能需要将WaitGroup实例传递给goroutine。可能有几个WaitGroup来处理不同的goroutine,也可能是一种设计选择。不管是什么原因,请确保传递指向WaitGroup的指针,像这样:

var wg sync.WaitGroup

for i := 0; i < 5; i++ {
    wg.Add(1)
    go func(wg *sync.WaitGroup) {
        defer wg.Done()

        fmt.Println(time.Now(), "start")
        time.Sleep(time.Second)
        fmt.Println(time.Now(), "done")
    }(&wg)
}

wg.Wait()
fmt.Println(time.Now(), "exiting...")

原因是Go是一种值传递的语言。这意味着每当你向一个函数传递一个参数时,Go会复制一个参数并传递给它而不是原始对象。在这种情况下发生的是,整个WaitGroup对象将被复制,这意味着goroutine将处理一个完全不同的WaitGroup。wg.Done()不会从原始的wg中减去,而是减去它的一个副本,这个副本只存在于goroutine中。

总结

通过使用WaitGroups,我们可以轻松同步goroutines,从而确保我们的代码在正确的时间执行。尽管通道也可以用于同步,但WaitGroups通常更直观且更易于阅读。在使用WaitGroup时,请确保正确传递指向WaitGroup的指针,以防止出现副本问题。无论您选择哪种方法,都应该选择最直观和最适合您和您的团队的方法。

到此这篇关于一文带你了解Golang中的WaitGroups的文章就介绍到这了,更多相关Golang WaitGroups内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们!

(0)

相关推荐

  • Go基础教程系列之WaitGroup用法实例详解

    正常情况下,新激活的goroutine(协程)的结束过程是不可控制的,唯一可以保证终止goroutine(协程)的行为是main goroutine(协程)的终止.也就是说,我们并不知道哪个goroutine(协程)什么时候结束. 但很多情况下,我们正需要知道goroutine(协程)是否完成.这需要借助sync包的WaitGroup来实现. WatiGroup是sync包中的一个struct类型,用来收集需要等待执行完成的goroutine(协程).下面是它的定义: type WaitGrou

  • Go并发控制WaitGroup的使用场景分析

    1. 前言 上一篇介绍了 Go并发控制--Channel 使用channel来控制子协程的优点是实现简单,缺点是当需要大量创建协程时就需要有相同数量的channel,而且对于子协程继续派生出来的协程不方便控制. 2. 使用WaitGroup控制 WaitGroup,可理解为Wait-Goroutine-Group,即等待一组goroutine结束.比如某个goroutine需要等待其他几个goroutine全部完成,那么使用WaitGroup可以轻松实现. 2.1 使用场景 下面程序展示了一个g

  • Go语言学习之WaitGroup用法详解

    目录 前言 小试牛刀 总览 底层实现 结构体 Add Done Wait 易错点 总结 前言 在前面的文章中,我们使用过 WaitGroup 进行任务编排,Go语言中的 WaitGroup 和 Java 中的 CyclicBarrier.CountDownLatch 非常类似.比如我们有一个主任务在执行,执行到某一点时需要并行执行三个子任务,并且需要等到三个子任务都执行完后,再继续执行主任务.那我们就需要设置一个检查点,使主任务一直阻塞在这,等三个子任务执行完后再放行. 说明:本文中的示例,均是

  • golang基础之waitgroup用法以及使用要点

    目录 一.前言 二.waitgroup使用示例 三.waitgroup使用注意事项 四.waitgroup使用总结 附:陷阱避免 总结 一.前言 waitgroup在golang中,用于线程同步,指等待一个组,等待一个系列执行完成后,才会向下执行,可以解决一个 进程goroutine 等待多个该进程启动的子线程goroutine 都正常运行完成的场景,这个比较常见的场景就是例如 后端 main processer 启动了多个消费者worker干活,还有爬虫并发爬取数据,多线程下载等等,为了保证主

  • 一文带你了解Golang中的WaitGroups

    目录 什么是WaitGroups 如何使用WaitGroups 为什么使用WaitGroups而不是channel 需要注意的一件事 总结 什么是WaitGroups WaitGroups是同步你的goroutines的一种有效方式.想象一下,你和你的家人一起驾车旅行.你的父亲在一个条形商场或快餐店停下来,买些食物和上厕所.你最好想等大家回来后再开车去地平线.WaitGroups帮助你做到这一点. WaitGroups是通过调用标准库中的sync包来定义的. var wg sync.WaitGr

  • 一文带你了解Golang中interface的设计与实现

    目录 前言 接口是什么 iface 和 eface 结构体 _type 是什么 itab 是什么 生成的 itab 是怎么被使用的 itab 关键方法的实现 根据 interfacetype 和 _type 初始化 itab 接口断言过程总览(类型转换的关键) panicdottypeI 与 panicdottypeE iface 和 eface 里面的 data 是怎么来的 convT* 方法 Java 里面的小整数享元模式 总结 在上一篇文章<go interface 基本用法>中,我们了

  • 一文带你了解Golang中的并发性

    目录 什么是并发性,为什么它很重要 并发性与平行性 Goroutines, the worker Mortys Channels, the green portal 总结 并发是一个很酷的话题,一旦你掌握了它,就会成为一笔巨大的财富.说实话,我一开始很害怕写这篇文章,因为我自己直到最近才对并发性不太适应.我已经掌握了基础知识,所以我想帮助其他初学者学习Go的并发性.这是众多并发性教程中的第一篇,请继续关注更多的教程. 什么是并发性,为什么它很重要 并发是指在同一时间运行多个事物的能力.你的电脑有

  • 一文带你了解Golang中select的实现原理

    目录 概述 结构 现象 非阻塞的收发 随机执行 编译 直接阻塞 独立情况 非阻塞操作 通用情况 运行时 初始化 循环 总结 概述 select是go提供的一种跟并发相关的语法,非常有用.本文将介绍 Go 语言中的 select 的实现原理,包括 select 的结构和常见问题.编译期间的多种优化以及运行时的执行过程. select 是一种与 switch 非常相似的控制结构,与 switch 不同的是,select 中虽然也有多个 case,但是这些 case 中的表达式都必须与 Channel

  • 一文带你掌握Golang Interface原理和使用技巧

    目录 1. interface 的基本概念 2. interface 的原理 3. interface 的使用技巧 3.1 使用空接口 3.2 使用类型断言 3.3 使用类型switch 3.4 使用接口组合 3.5 将方法定义在interface类型中 3.6 使用匿名接口嵌套 4. interface 的常见使用场景 4.1 依赖注入 4.2 测试驱动开发 4.3 框架设计 5. 总结 Golang 中的 interface 是一种非常重要的特性,可以让我们写出更加灵活的代码.interfa

  • 一文带你理解 Vue 中的生命周期

    目录 1.beforeCreate & created 2.beforeMount & mounted 3.beforeUpdate & updated 4.beforeDestroy & destroyed 5.activated & deactivated 前言: 每个 Vue 实例在被创建之前都要经过一系列的初始化过程.例如需要设置数据监听.编译模板.挂载实例到 DOM.在数据变化时更新 DOM 等.同时在这个过程中也会运行一些叫做生命周期钩子的函数,给予用户

  • 一文带你掌握Java8中Lambda表达式 函数式接口及方法构造器数组的引用

    目录 函数式接口概述 函数式接口示例 1.Runnable接口 2.自定义函数式接口 3.作为参数传递 Lambda 表达式 内置函数式接口 Lambda简述 Lambda语法 方法引用 构造器引用 数组引用 函数式接口概述 只包含一个抽象方法的接口,称为函数式接口. 可以通过 Lambda 表达式来创建该接口的对象. 可以在一个接口上使用 @FunctionalInterface 注解,这样做可以检查它是否是一个函数式接口.同时 javadoc 也会包含一条声明,说明这个接口是一个函数式接口.

  • 一文带你了解Java中的ForkJoin

    目录 什么是ForkJoin? ForkJoinTask 任务 ForkJoinPool 线程池 工作窃取算法 构造方法 提交方法 创建工人(线程) 例:ForkJoinTask实现归并排序 ForkJoin计算流程 前言: ForkJoin是在Java7中新加入的特性,大家可能对其比较陌生,但是Java8中Stream的并行流parallelStream就是依赖于ForkJoin.在ForkJoin体系中最为关键的就是ForkJoinTask和ForkJoinPool,ForkJoin就是利用

  • 一文带你了解Java中的Object类及类中方法

    目录 1. Object类介绍 2. 重写toString方法打印对象 3. 对象比较equals方法 4. hashCode方法 1. Object类介绍 Object是Java默认提供的一个类.Java里面除了Object类,所有的类都是存在继承关系的.默认会继承Object父 类.即所有类的对象都可以使用Object的引用进行接收. 范例:使用Object接收所有类的对象 class Person{} class Student{} public class Test { public s

  • 一文带你了解Qt中槽的使用

    目录 一.建立槽和按钮之间的连接 二.槽函数的定义 一.建立槽和按钮之间的连接 connect(信号发送者,发送的信号,信号接收者,信号接收者的槽函数) 1.例子 connect(ui->pushButton,SIGNAL(clicked(bool)),this,SLOT(showinfo())); 解释: 信号反发送者:pushButton(这是一个按钮),发送信号:clicked(点击按钮),信号接收者:this(本类),信号接收者的槽函数:showinfo(点击按钮后响应的函数) 二.槽函

随机推荐