Go 언어의 WaitGroups는 무엇인가요? 사용하는 방법?-Golang-php.cn

WaitGroup이 무엇인가요? 다음 글에서는 Go 언어의 WaitGroups를 이해하고 WaitGroups 사용 방법을 소개하겠습니다. 도움이 되기를 바랍니다.

Go 언어의 WaitGroups는 무엇인가요? 사용하는 방법?

WaitGroup이 무엇인가요?

WaitGroups는 고루틴을 동기화하는 효율적인 방법입니다. 가족과 함께 자동차로 여행한다고 상상해보십시오. 당신의 아버지는 길거리 쇼핑몰이나 패스트푸드점에 들러 음식을 사고 화장실을 사용합니다. Horizon으로 운전하기 전에 모두가 돌아올 때까지 기다리는 것이 좋습니다. WaitGroups는 이를 수행하는 데 도움이 됩니다. WaitGroups是同步你的goroutines的一种有效方式。想象一下，你和你的家人一起驾车旅行。你的父亲在一个条形商场或快餐店停下来，买些食物和上厕所。你最好想等大家回来后再开车去地平线。WaitGroups帮助你做到这一点。

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

var wg sync.WaitGroup

로그인 후 복사

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

WaitGroups有三个最重要的方法: Add, Done和 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는 표준 라이브러리에서 sync 패키지를 호출하여 정의됩니다. 🎜rrreee🎜그럼 WaitGroup은 무엇인가요? WaitGroup은 프로그램이 기다려야 하는 고루틴 수에 대한 특정 정보를 포함하는 구조입니다. 기다려야 하는 고루틴의 개수가 포함된 그룹입니다. 🎜🎜WaitGroups에는 Add, Done 및 Wait의 세 가지 가장 중요한 방법이 있습니다. 🎜

추가: 기다려야 하는 총 고루틴 수에 추가합니다.
완료: 기다려야 하는 총 고루틴 수에서 1을 뺍니다.
대기: 더 이상 기다릴 고루틴이 없을 때까지 코드가 계속되는 것을 방지합니다.

🎜🎜WaitGroups 사용 방법🎜🎜🎜코드를 살펴보겠습니다. 🎜rrreeerrreee

먼저 WaitGroup wg의 인스턴스를 초기화합니다. .
그런 다음 goroutine이 완료될 때까지 기다려야 하기 때문에 wg에 1을 추가합니다.
그런 다음 이 고루틴을 실행합니다. goroutine 내에서 대기할 goroutine 수를 줄이기 위해 wg.Done()에 대한 지연된 호출을 수행합니다. 이렇게 하지 않으면 코드는 goroutine이 완료될 때까지 영원히 기다리며 교착 상태가 발생합니다.
goroutine 호출 후에는 WaitGroup이 빌 때까지 코드를 차단해야 합니다. wg.Wait()를 호출하여 이를 수행합니다.

🎜🎜채널 대신 WaitGroups를 사용하는 이유는 무엇입니까? 🎜🎜🎜이제 WaitGroups 사용 방법을 알았으므로 자연스러운 생각으로 인해 채널 대신 WaitGroups를 사용하는 이유는 무엇입니까? 🎜🎜내 경험에 따르면 몇 가지 이유가 있습니다. 🎜

WaitGroups는 더 직관적인 경향이 있습니다. 코드를 읽을 때 WaitGroup을 보면 코드가 수행하는 작업을 즉시 알 수 있습니다. 메소드 이름은 명확하고 요점을 알 수 있습니다. 그러나 채널을 사용하면 때로는 명확하지 않습니다. 채널을 사용하는 것은 현명하지만 복잡한 코드를 읽을 때는 이해하기 어려울 수 있습니다.
채널을 사용할 필요가 없는 경우도 있습니다. 예를 들어 다음 코드를 살펴보겠습니다.

rrreee🎜 이 고루틴은 다른 고루틴과 통신하지 않는다는 것을 알 수 있습니다. goroutine이 일회성 작업이고 결과를 알 필요가 없다면 WaitGroup을 사용하는 것이 좋습니다. 이제 다음 코드를 살펴보세요. 🎜rrreee🎜여기서 goroutine이 channel로 데이터를 보내고 있습니다. 이러한 경우 중복되므로 WaitGroup을 사용할 필요가 없습니다. 수신이 이미 충분한 차단을 수행했다면 왜 goroutine이 완료될 때까지 기다리나요? 🎜🎜WaitGroups는 특히 goroutines 대기를 처리하는 데 사용됩니다. 채널의 주요 목적은 데이터를 전달하는 것이라고 생각합니다. WaitGroup을 사용하여 데이터를 보내고 받을 수는 없지만 채널을 사용하여 goroutines를 동기화할 수 있습니다. 🎜🎜결국 정답은 없습니다. 이것이 짜증스러울 수 있다는 것을 알지만 이는 귀하와 귀하가 일하는 팀에 달려 있습니다. 어떤 방법이 최선이든 정답은 없습니다. 저는 개인적으로 동기화를 위해 WaitGroups를 사용하는 것을 선호하지만 상황은 다를 수 있습니다. 당신에게 가장 직관적으로 느껴지는 것을 선택하세요. 🎜🎜🎜주의할 점🎜🎜🎜때로는 WaitGroup 인스턴스를 goroutine에 전달해야 할 수도 있습니다. 다양한 고루틴을 처리하기 위해 여러 WaitGroup이 있을 수도 있고 디자인적으로 선택할 수도 있습니다. 이유가 무엇이든 다음과 같이 WaitGroup에 대한 포인터를 전달해야 합니다. 🎜rrreee🎜이유는 Go가 값 전달 언어이기 때문입니다. 즉, 함수에 인수를 전달할 때마다 Go는 인수를 복사하여 원래 객체 대신 전달합니다. 이 경우 발생하는 일은 전체 WaitGroup 개체가 복사된다는 것입니다. 이는 goroutine이 완전히 다른 WaitGroup을 처리한다는 것을 의미합니다. wg.Done()은 원본 wg에서 빼지 않고 goroutine에만 존재하는 복사본을 뺍니다. 🎜

요약

복사 문제를 방지하기 위해 WaitGroups，我们可以轻松同步goroutines，从而确保我们的代码在正确的时间执行。尽管通道也可以用于同步，但WaitGroups通常更直观且更易于阅读。在使用WaitGroup时，请确保正确传递指向WaitGroup 포인터를 사용합니다. 어떤 방법을 선택하든 가장 직관적이고 귀하와 귀하의 팀에 가장 적합한 방법을 선택하십시오.