php-Editor Strawberry stellt Ihnen in diesem Artikel einen häufigen Programmierfehler vor: Schwerwiegender Fehler: „Alle Goroutinen schlafen – Deadlock! Fehler bei der Ausführung“. Dies ist einer der häufigsten Fehler in der Go-Sprache und eine der Herausforderungen, mit denen Entwickler häufig konfrontiert werden. In diesem Artikel erklären wir die Ursache und Lösung dieses Fehlers im Detail, um allen zu helfen, dieses Problem besser zu verstehen und zu lösen. Egal, ob Sie Anfänger oder erfahrener Entwickler sind, in diesem Artikel erhalten Sie wertvolle Informationen und Tipps. Lasst uns gemeinsam erkunden!
Ich bin ein Neuling in der Parallelität in Go, daher habe ich ein Beispiel mit Kanälen und Goroutinen ausprobiert. Ich möchte das Produzenten-Konsumenten-Modell. Die Produzentenfunktion gibt immer zufällige Zeichenfolgen aus und der Verbraucher ändert sie, indem er sie in Großbuchstaben umwandelt. Ich möchte es für eine begrenzte Zeit (2 Sekunden) ausführen.
package main import ( "fmt" "math/rand" "strings" "time" ) func producer(x []string, c chan string) { i := 1 for i > 0 { randomIndex := rand.Intn(len(x)) pick := x[randomIndex] c <- pick } } func consumer(x string, c chan string) { x1 := strings.ToUpper(x) c <- x1 } func main() { s := []string{"one", "two", "three", "four"} c1 := make(chan string) d1 := make(chan string) go producer(s, c1) go consumer(<-c1, d1) stop := time.After(2000 * time.Millisecond) for { select { case <-stop: fmt.Println("STOP AFTER 2 SEC!") return default: fmt.Println(<-d1) time.Sleep(50 * time.Millisecond) } } }
Ich erhalte nur ein Array-Element und einige Fehler. Welche Änderungen müssen vorgenommen werden, damit dieses Beispiel funktioniert?
Ausgabe:
Zwei
FATALER FEHLER: Alle Goroutinen schlafen – Stillstand!
goroutine 1 [chan empfangen]: main.main()
Coroutine 6 [chan send]: main.producer({0xc00004e040, 0x4, 0x0?}, 0x0?) Erstellt von main. hauptsächlich Exit-Status 2
Ihr Verbraucher sollte in einer Schleife laufen, dies wurde bereits erwähnt.
Ändern Sie den ersten Parameter des Verbrauchers so, dass er chan字符串
anstelle einer Zeichenfolge ist. Auf diese Weise kann der Produzent bis zum Ablauf der Frist weiterhin auf diesem Kanal schreiben, damit der Verbraucher auf einem anderen Kanal veröffentlichen kann.
func consumer(consumechan chan string, outch chan string) { for { select { case s := <- consumechan: s = strings.toupper(s) outch <- s } } }
Beim Aufruf go consumer()
之前的主函数中,您正在等待生产者对 c1
通道的第一个响应。不要这样做,而是将 c1
wird nun der Kanal als erstes Argument übergeben.
func main() { s := []string{"one", "two", "three", "four"} c1 := make(chan string) d1 := make(chan string) go producer(s, c1) go consumer(c1, d1) stop := time.After(2000 * time.Millisecond) for { select { case <-stop: fmt.Println("STOP AFTER 2 SEC!") return case response := <- d1: fmt.Println(response) time.Sleep(50 * time.Millisecond) } } }
Dies sollte zeigen, dass der Produzent kontinuierlich Zufallszahlen auf dem Kanal c1
schreibt und der Verbraucher kontinuierlich Text in Großbuchstaben auf dem Kanal d1 schreibt, bis die 2 Sekunden abgelaufen sind.
Das obige ist der detaillierte Inhalt vonSchwerwiegender Fehler: Alle Goroutinen schlafen – Deadlock! Fehlerhafte Ausführung. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!