suchen
HeimBackend-EntwicklungGolangBitten Sie Go, alle Goroutinen auszuführen, bevor Sie fortfahren

在继续之前要求 Go 运行所有 goroutine

Bei der gleichzeitigen Programmierung stoßen wir oft auf Situationen, in denen wir warten müssen, bis alle Goroutinen abgeschlossen sind, bevor wir mit der Ausführung fortfahren. In der Go-Sprache können wir dieses Ziel erreichen, indem wir WaitGroup verwenden. WaitGroup ist ein Zählsemaphor, mit dem auf den Abschluss einer Gruppe von Goroutinen gewartet werden kann. Bevor wir fortfahren, müssen wir die Wait-Methode von WaitGroup aufrufen, um sicherzustellen, dass alle Goroutinen ihre Aufgaben abgeschlossen haben. In diesem Artikel stellen wir vor, wie WaitGroup korrekt zum Verwalten der Ausführungsreihenfolge von Goroutinen verwendet wird.

Frageninhalt

Ich benötige den Golang-Scheduler, um alle Goroutinen auszuführen, bevor ich fortfahre. runtime.gosched() kann das Problem nicht lösen.

Das Problem ist, dass die Go-Routine so schnell läuft, dass das „select“ in start() nach dem „select“ in stopstream() ausgeführt wird und dann „case

Führen Sie diesen Code aus https://go.dev/play/p/dq85xqju2q_z Oft werden Sie diese beiden Antworten sehen Erwartete Antwort, wenn nicht suspendiert:

2009/11/10 23:00:00 start
2009/11/10 23:00:00 receive chan
2009/11/10 23:00:03 end

Erwartete Reaktion bei Suspendierung, aber nicht so schnell bei Suspendierung:

2009/11/10 23:00:00 start
2009/11/10 23:00:00 default
2009/11/10 23:00:01 timer
2009/11/10 23:00:04 end

Code

package main

import (
    "log"
    "runtime"
    "sync"
    "time"
)

var wg sync.WaitGroup

func main() {
    wg.Add(1)
    //run multiples routines on a huge system
    go start()
    wg.Wait()
}
func start() {
    log.Println("Start")
    chanStopStream := make(chan bool)
    go stopStream(chanStopStream)
    select {
    case <-chanStopStream:
        log.Println("receive chan")
    case <-time.After(time.Second): //if stopStream hangs do not wait more than 1 second
        log.Println("TIMER")
        //call some crash alert
    }
    time.Sleep(3 * time.Second)
    log.Println("end")
    wg.Done()
}

func stopStream(retChan chan bool) {
    //do some work that can be faster then caller or not
    runtime.Gosched()
    //time.Sleep(time.Microsecond) //better solution then runtime.Gosched()
    //time.Sleep(2 * time.Second) //simulate when this routine hangs more than 1 second
    select {
    case retChan <- true:
    default: //select/default is used because if the caller times out this routine will hangs forever
        log.Println("default")
    }
}

Workaround

Es gibt keine Möglichkeit, alle anderen Goroutinen auszuführen, bevor die Ausführung der aktuellen Goroutine fortgesetzt wird.

Das Problem wurde behoben, indem sichergestellt wurde, dass die Goroutine nicht blockiert stopstream:

Option 1: Ändern Sie chanstopstream in gepufferter Kanal chanstopstream 更改为缓冲通道。这确保了 stopstream. Dadurch wird sichergestellt, dass

Werte ohne Blockierung senden kann.

func start() {
    log.println("start")
    chanstopstream := make(chan bool, 1) // <--- buffered channel
    go stopstream(chanstopstream)
    ...
}

func stopstream(retchan chan bool) {
    ...
    // always send. no select/default needed.
    retchan <- true
}
https://www.php.cn/link/56e48d306028f2a6c2ebf677f7e8f800

Option 2

: Schließen Sie den Kanal, anstatt den Wert zu senden. Kanäle können jederzeit vom Absender geschlossen werden. Empfängt einen Nullwert auf einem geschlossenen Kanal, der den Kanalwerttyp zurückgibt.

func start() {
    log.Println("Start")
    chanStopStream := make(chan bool) // buffered channel not required
    go stopStream(chanStopStream)
    ...

func stopStream(retChan chan bool) {
    ...
    close(retChan)
}
https://www.php.cn/link/a1aa0c486fb1a7ddd47003884e1fc67f

🎜

Das obige ist der detaillierte Inhalt vonBitten Sie Go, alle Goroutinen auszuführen, bevor Sie fortfahren. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Stellungnahme
Dieser Artikel ist reproduziert unter:stackoverflow. Bei Verstößen wenden Sie sich bitte an admin@php.cn löschen
C und Golang: Wenn die Leistung von entscheidender Bedeutung istC und Golang: Wenn die Leistung von entscheidender Bedeutung istApr 13, 2025 am 12:11 AM

C eignet sich besser für Szenarien, in denen eine direkte Kontrolle der Hardware -Ressourcen und hohe Leistungsoptimierung erforderlich ist, während Golang besser für Szenarien geeignet ist, in denen eine schnelle Entwicklung und eine hohe Parallelitätsverarbeitung erforderlich sind. 1.Cs Vorteil liegt in den nahezu Hardware-Eigenschaften und hohen Optimierungsfunktionen, die für leistungsstarke Bedürfnisse wie die Spieleentwicklung geeignet sind. 2. Golangs Vorteil liegt in seiner präzisen Syntax und der natürlichen Unterstützung, die für die Entwicklung einer hohen Parallelitätsdienste geeignet ist.

Golang in Aktion: Beispiele und Anwendungen in realer WeltGolang in Aktion: Beispiele und Anwendungen in realer WeltApr 12, 2025 am 12:11 AM

Golang zeichnet sich in praktischen Anwendungen aus und ist für seine Einfachheit, Effizienz und Parallelität bekannt. 1) Die gleichzeitige Programmierung wird über Goroutinen und Kanäle implementiert, 2) Flexibler Code wird unter Verwendung von Schnittstellen und Polymorphismen geschrieben, 3) Vereinfachen Sie die Netzwerkprogrammierung mit NET/HTTP -Paketen, 4) Effiziente gleichzeitige Crawler erstellen, 5) Debuggen und Optimierung durch Tools und Best Practices.

Golang: Die Go -Programmiersprache erklärtGolang: Die Go -Programmiersprache erklärtApr 10, 2025 am 11:18 AM

Zu den Kernmerkmalen von GO gehören die Müllsammlung, statische Verknüpfung und Unterstützung der Parallelität. 1. Das Parallelitätsmodell von GO -Sprache realisiert eine effiziente gleichzeitige Programmierung durch Goroutine und Kanal. 2. Schnittstellen und Polymorphismen werden durch Schnittstellenmethoden implementiert, so dass verschiedene Typen einheitlich verarbeitet werden können. 3. Die grundlegende Verwendung zeigt die Effizienz der Funktionsdefinition und des Aufrufs. 4. In der fortgeschrittenen Verwendung bieten Scheiben leistungsstarke Funktionen der dynamischen Größenänderung. 5. Häufige Fehler wie Rassenbedingungen können durch Getest-Race erkannt und gelöst werden. 6. Leistungsoptimierung wiederverwenden Objekte durch Sync.Pool, um den Druck der Müllabfuhr zu verringern.

Golangs Zweck: Aufbau effizienter und skalierbarer SystemeGolangs Zweck: Aufbau effizienter und skalierbarer SystemeApr 09, 2025 pm 05:17 PM

Go Language funktioniert gut beim Aufbau effizienter und skalierbarer Systeme. Zu den Vorteilen gehören: 1. hohe Leistung: Kompiliert in den Maschinencode, schnelle Laufgeschwindigkeit; 2. gleichzeitige Programmierung: Vereinfachen Sie Multitasking durch Goroutinen und Kanäle; 3. Einfachheit: präzise Syntax, Reduzierung der Lern- und Wartungskosten; 4. plattform: Unterstützt die plattformübergreifende Kompilierung, einfache Bereitstellung.

Warum scheinen die Ergebnisse der Ordnung nach Aussagen in der SQL -Sortierung manchmal zufällig zu sein?Warum scheinen die Ergebnisse der Ordnung nach Aussagen in der SQL -Sortierung manchmal zufällig zu sein?Apr 02, 2025 pm 05:24 PM

Verwirrt über die Sortierung von SQL -Abfragenergebnissen. Während des Lernens von SQL stoßen Sie häufig auf einige verwirrende Probleme. Vor kurzem liest der Autor "Mick-SQL Basics" ...

Ist die Konvergenz für Technologiestapel nur ein Prozess der Technologie -Stapelauswahl?Ist die Konvergenz für Technologiestapel nur ein Prozess der Technologie -Stapelauswahl?Apr 02, 2025 pm 05:21 PM

Die Beziehung zwischen Technologiestapelkonvergenz und Technologieauswahl in der Softwareentwicklung, der Auswahl und dem Management von Technologiestapeln ist ein sehr kritisches Problem. In letzter Zeit haben einige Leser vorgeschlagen ...

Wie kann man den Reflexionsvergleich verwenden und die Unterschiede zwischen drei Strukturen in GO verwandeln?Wie kann man den Reflexionsvergleich verwenden und die Unterschiede zwischen drei Strukturen in GO verwandeln?Apr 02, 2025 pm 05:15 PM

Wie man drei Strukturen in der GO -Sprache vergleicht und umgeht. Bei der Go -Programmierung ist es manchmal notwendig, die Unterschiede zwischen zwei Strukturen zu vergleichen und diese Unterschiede auf die ...

See all articles

Heiße KI -Werkzeuge

Undresser.AI Undress

Undresser.AI Undress

KI-gestützte App zum Erstellen realistischer Aktfotos

AI Clothes Remover

AI Clothes Remover

Online-KI-Tool zum Entfernen von Kleidung aus Fotos.

Undress AI Tool

Undress AI Tool

Ausziehbilder kostenlos

Clothoff.io

Clothoff.io

KI-Kleiderentferner

AI Hentai Generator

AI Hentai Generator

Erstellen Sie kostenlos Ai Hentai.

Heißer Artikel

R.E.P.O. Energiekristalle erklärten und was sie tun (gelber Kristall)
3 Wochen vorBy尊渡假赌尊渡假赌尊渡假赌
R.E.P.O. Beste grafische Einstellungen
3 Wochen vorBy尊渡假赌尊渡假赌尊渡假赌
R.E.P.O. So reparieren Sie Audio, wenn Sie niemanden hören können
3 Wochen vorBy尊渡假赌尊渡假赌尊渡假赌
WWE 2K25: Wie man alles in Myrise freischaltet
4 Wochen vorBy尊渡假赌尊渡假赌尊渡假赌

Heiße Werkzeuge

WebStorm-Mac-Version

WebStorm-Mac-Version

Nützliche JavaScript-Entwicklungstools

Senden Sie Studio 13.0.1

Senden Sie Studio 13.0.1

Leistungsstarke integrierte PHP-Entwicklungsumgebung

DVWA

DVWA

Damn Vulnerable Web App (DVWA) ist eine PHP/MySQL-Webanwendung, die sehr anfällig ist. Seine Hauptziele bestehen darin, Sicherheitsexperten dabei zu helfen, ihre Fähigkeiten und Tools in einem rechtlichen Umfeld zu testen, Webentwicklern dabei zu helfen, den Prozess der Sicherung von Webanwendungen besser zu verstehen, und Lehrern/Schülern dabei zu helfen, in einer Unterrichtsumgebung Webanwendungen zu lehren/lernen Sicherheit. Das Ziel von DVWA besteht darin, einige der häufigsten Web-Schwachstellen über eine einfache und unkomplizierte Benutzeroberfläche mit unterschiedlichen Schwierigkeitsgraden zu üben. Bitte beachten Sie, dass diese Software

Herunterladen der Mac-Version des Atom-Editors

Herunterladen der Mac-Version des Atom-Editors

Der beliebteste Open-Source-Editor

Dreamweaver CS6

Dreamweaver CS6

Visuelle Webentwicklungstools