Heim >Backend-Entwicklung >Golang >Golang-Parallelprogrammierung: Verwenden Sie Go WaitGroup, um den Taskplaner zu implementieren
Gleichzeitige Golang-Programmierung: Verwenden Sie Go WaitGroup, um den Aufgabenplaner zu implementieren
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.
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.
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.
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!