Wie kann sichergestellt werden, dass alle Goroutinen vollständig sind, wenn ein gepufferter Kanal als Semaphor verwendet wird?

Warten auf einen leeren gepufferten Kanal (Semaphor)

Bei der gleichzeitigen Programmierung ist es wichtig zu steuern, wie viele Goroutinen gleichzeitig ausgeführt werden. Ein Ansatz besteht darin, einen gepufferten Kanal als Semaphor zu verwenden. Ein häufiges Problem tritt jedoch auf, wenn darauf gewartet wird, dass das Semaphor vollständig entleert ist.

Problem:

Angenommen, wir haben eine Reihe von Ganzzahlen, die wir gleichzeitig verarbeiten möchten, mit einem Limit von zwei gleichzeitigen Gehen Sie Routinen. Wir verwenden einen gepufferten Kanal als Semaphor, um dieses Limit durchzusetzen. Während der Code für die meisten Ganzzahlen funktioniert, wird das Programm vorzeitig beendet, bevor die Last-Go-Routinen abgeschlossen sind, da der Puffer nie den leeren Bereich erreicht.

Die Frage:

Wie warten wir, bis der gepufferte Kanal verfügbar ist? Vollständig entleeren und sicherstellen, dass alle Go-Routinen abgeschlossen sind, bevor das Programm beendet wird?

Antwort:

Verwenden eines Kanals zum Warten auf a Eine bestimmte Bedingung ist nicht realisierbar, da es keine rennfreie Möglichkeit gibt, die Länge zu überprüfen. Stattdessen können wir eine sync.WaitGroup verwenden, um den Abschluss aller Goroutinen zu überwachen.

Aufgelöster Code:

sem := make(chan struct{}, 2)

var wg sync.WaitGroup

for _, i := range ints {
    wg.Add(1)
    // acquire semaphore
    sem <p>Durch die Verwendung von sync.WaitGroup können wir vorher warten, bis alle Goroutinen abgeschlossen sind Das Programm wird beendet und stellt sicher, dass die gesamte Verarbeitung abgeschlossen ist.</p>

Das obige ist der detaillierte Inhalt vonWie kann sichergestellt werden, dass alle Goroutinen vollständig sind, wenn ein gepufferter Kanal als Semaphor verwendet wird?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!