Golang-Parallelprogrammierung: Verwenden Sie Go WaitGroup, um den Taskplaner zu implementieren

Gleichzeitige Golang-Programmierung: Verwenden Sie Go WaitGroup, um den Aufgabenplaner zu implementieren

1. Einführung
   In Golang kann die Implementierung gleichzeitiger Programmierung die Leistung und Effizienz des Programms erheblich verbessern. Der Taskplaner ist ein sehr wichtiger Bestandteil der gleichzeitigen Programmierung. Er kann zum Planen der Ausführungsreihenfolge gleichzeitiger Aufgaben und der Ausführung synchronisierter Aufgaben verwendet werden. In diesem Artikel wird erläutert, wie Sie mit WaitGroup in Golang einen einfachen Aufgabenplaner implementieren, und es werden spezifische Codebeispiele gegeben.
2. Einführung in WaitGroup
   WaitGroup ist ein wichtiger Typ in der Golang-Paketsynchronisierung, der Synchronisierungs- und Wartefunktionen für gleichzeitige Aufgaben bereitstellt. WaitGroup verfügt über drei Hauptmethoden: Hinzufügen, Fertig und Warten.

• Add(n int): n gleichzeitige Aufgaben zur WaitGroup hinzufügen.
• Done(): Eine Aufgabe als erledigt markieren.
• Wait(): Warten Sie, bis alle Aufgaben abgeschlossen sind, und blockieren Sie die aktuelle Goroutine.

WaitGroup führt intern einen Zähler, um die Anzahl der nicht erledigten Aufgaben zu erfassen. Wenn die Add-Methode aufgerufen wird, wird der Zähler um den angegebenen Wert erhöht. Wenn die Done-Methode aufgerufen wird, wird der Zähler um 1 verringert. Wenn der Zähler größer als 0 ist, wird die aktuelle Goroutine aufgerufen blockiert, bis der Zähler auf Null zurückkehrt.

3. Implementierung des Aufgabenplaners
   Hier ist ein Beispielcode, der WaitGroup verwendet, um einen Aufgabenplaner zu implementieren:

package main

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

func worker(id int, wg *sync.WaitGroup) {
    defer wg.Done()
    fmt.Printf("Worker %d starting
", id)
    time.Sleep(time.Second)
    fmt.Printf("Worker %d done
", id)
}

func main() {
    var wg sync.WaitGroup
    for i := 1; i <= 5; i++ {
        wg.Add(1)
        go worker(i, &wg)
    }
    wg.Wait()
    fmt.Println("All workers done")
}

In diesem Beispiel verwenden wir eine for-Schleife, um 5 Worker-Goroutinen zu starten, und rufen wg.Add(1) auf, um diese hinzuzufügen Anzahl der Aufgaben an die WaitGroup. Verwenden Sie in der Worker-Funktion das Schlüsselwort defer, um sicherzustellen, dass wg.Done() aufgerufen wird, bevor die Funktion zurückkehrt, um den Zählerwert zu dekrementieren. Verwenden Sie abschließend wg.Wait(), um zu warten, bis alle Aufgaben abgeschlossen sind.

4. Ergebnisse ausführen
   Führen Sie diesen Beispielcode aus. Sie sehen die folgende Ausgabe:

Worker 1 starting
Worker 2 starting
Worker 3 starting
Worker 4 starting
Worker 5 starting
Worker 3 done
Worker 1 done
Worker 2 done
Worker 5 done
Worker 4 done
All workers done

Sie können sehen, dass alle Worker-Goroutinen gleichzeitig ausgeführt werden, die Reihenfolge der Ausgabe jedoch nicht unbedingt der Startreihenfolge entspricht. Dies liegt an der Goroutine Die Planung erfolgt durch die Go-Laufzeit.

5. Zusammenfassung
   Mit WaitGroup kann die Planung und Synchronisierung gleichzeitiger Aufgaben problemlos implementiert werden. Durch Aufrufen der Add-Methode zum Hinzufügen der Anzahl der Aufgaben, Aufrufen der Done-Methode zum Markieren des Aufgabenabschlusses und Aufrufen der Wait-Methode zum Warten auf den Aufgabenabschluss können Aufgabensynchronisierung und Sequenzkontrolle erreicht werden. In praktischen Anwendungen kann der Aufgabenplaner verwendet werden, um gleichzeitige Aufgaben zu bearbeiten, die Anzahl der Parallelitäten zu begrenzen und andere Szenarien zu begrenzen, was uns dabei hilft, die Parallelitätsfunktionen von Golang besser zu nutzen.

Durch die Einführung und den Beispielcode dieses Artikels glaube ich, dass Sie ein tieferes Verständnis dafür haben, wie Sie mit Golangs WaitGroup einen Aufgabenplaner implementieren. Ich hoffe, dieser Artikel hilft Ihnen beim Erlernen und Verwenden der gleichzeitigen Programmierung in Golang!

Das obige ist der detaillierte Inhalt vonGolang-Parallelprogrammierung: Verwenden Sie Go WaitGroup, um den Taskplaner zu implementieren. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!