Wie wartet die Golang-Funktion über WaitGroup darauf, dass die Goroutine abgeschlossen wird?

WaitGroup ist ein Synchronisierungsmechanismus in Go zur Koordinierung der Goroutine-Ausführung. Damit stellen Sie sicher, dass die Haupt-Goroutine auf den Abschluss einer Gruppe von Goroutinen wartet, bevor sie mit der Ausführung fortfährt. Spezifische Verwendung: Erstellen Sie eine WaitGroup-Instanz und legen Sie einen Anfangszähler dafür fest, der die Anzahl der Goroutinen angibt, auf die gewartet werden soll. Rufen Sie für jede Goroutine, auf die gewartet werden soll, wg.Add(1) auf, um den Zähler zu erhöhen. Rufen Sie nach Abschluss der Goroutine wg.Done() auf, um den Zähler zu dekrementieren. Schließlich ruft die Haupt-Goroutine wg.Wait() auf, um sich selbst zu blockieren, bis alle Goroutinen abgeschlossen sind.

So verwenden Sie WaitGroup, um in Go auf den Abschluss von Goroutine zu warten

WaitGroup in Go ist ein Synchronisierungsmechanismus, der zur Koordinierung der Ausführung mehrerer Goroutinen verwendet wird. Dadurch kann die Haupt-Goroutine auf den Abschluss einer Gruppe von Goroutinen warten und so sicherstellen, dass alle zugehörigen Aufgaben abgeschlossen sind, bevor mit der Ausführung fortgefahren wird. WaitGroup 是一种同步机制，用于协调多个 goroutine 的执行。它允许主 goroutine 等待一组 goroutine 完成，从而确保在继续执行之前所有相关任务都已完成。

用法：

创建一个 WaitGroup 实例，并为其设置一个初始计数器，表示要等待的 goroutine 数。对于每个要等待的 goroutine，调用 wg.Add(1) 来增加计数器，并在 goroutine 完成后调用 wg.Done() 来减少计数器。最后，主 goroutine 调用 wg.Wait() 来阻塞自身，直到所有 goroutine 都已完成。

代码示例：

package main

import (
    "fmt"
    "sync"
)

var wg sync.WaitGroup

func main() {
    // 创建一个需要等待 3 个 goroutine 完成的 WaitGroup
    wg.Add(3)

    // 创建 3 个 goroutine
    for i := 0; i < 3; i++ {
        go func(i int) {
            fmt.Printf("Goroutine %d started\n", i)
            
            // 模拟一些需要时间的工作
            for j := 0; j < 10000; j++ {}
            
            fmt.Printf("Goroutine %d finished\n", i)
            
            // 通知 WaitGroup 该 goroutine 已完成
            wg.Done()
        }(i)
    }

    // 等待所有 goroutine 完成
    wg.Wait()
    fmt.Println("All goroutines have finished")
}

实战案例：

此代码示例模拟了一个简单的 Web 服务器，该服务器会启动多个 goroutine 来处理请求。为了确保在关闭服务器之前 goroutine 已完成，我们使用 WaitGroup

🎜Verwendung: 🎜🎜🎜Erstellen Sie eine WaitGroup-Instanz und legen Sie einen Anfangszähler dafür fest, der die Anzahl der Goroutinen angibt, auf die gewartet werden soll. Für jede Goroutine, auf die gewartet werden soll, rufen Sie wg.Add(1) auf, um den Zähler zu erhöhen, und wenn die Goroutine abgeschlossen ist, rufen Sie wg.Done() auf, um den Zähler zu dekrementieren. Schließlich ruft die Haupt-Goroutine wg.Wait() auf, um sich selbst zu blockieren, bis alle Goroutinen abgeschlossen sind. 🎜🎜🎜Codebeispiel: 🎜🎜

package main

import (
    "fmt"
    "net/http"
    "sync"
)

var wg sync.WaitGroup

func main() {
    // 创建一个需要等待所有 HTTP 请求完成的 WaitGroup
    wg.Add(10)

    // 监听端口 8080
    http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
        fmt.Fprintf(w, "Hello, World!")
        
        // 请求处理完毕后，通知 WaitGroup
        wg.Done()
    })
    http.ListenAndServe(":8080", nil)
    
    // 等待所有 HTTP 请求完成
    wg.Wait()
    fmt.Println("All HTTP requests have been processed")
}

🎜🎜Praktischer Fall: 🎜🎜🎜Dieses Codebeispiel simuliert einen einfachen Webserver, der mehrere Goroutinen startet, um Anfragen zu bearbeiten. Um sicherzustellen, dass die Goroutinen abgeschlossen sind, bevor der Server heruntergefahren wird, verwenden wir WaitGroup, um auf den Abschluss aller Goroutinen zu warten. 🎜rrreee

Das obige ist der detaillierte Inhalt vonWie wartet die Golang-Funktion über WaitGroup darauf, dass die Goroutine abgeschlossen wird?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!