Rumah  >  Artikel  >  pembangunan bahagian belakang  >  Mengapa saya mendapat - goroutine adalah ralat tidur kerana isu pengguna pengeluar

Mengapa saya mendapat - goroutine adalah ralat tidur kerana isu pengguna pengeluar

WBOY
WBOYke hadapan
2024-02-10 21:40:25976semak imbas

为什么我会收到 - goroutines are sleeped 错误,因为生产者消费者问题

Editor PHP Youzi mungkin menghadapi mesej ralat biasa semasa menyelesaikan masalah pengaturcaraan: "goroutine sedang tidur". Ralat ini biasanya berkaitan dengan isu pengeluar-pengguna. Masalah pengeluar-pengguna ialah senario klasik dalam pengaturcaraan serentak, di mana satu atau lebih pengeluar menjana data dan satu atau lebih pengguna mengeluarkan data untuk diproses. Apabila pengeluar menjana data lebih pantas daripada pengguna boleh memproses data, ia boleh menyebabkan goroutine (benang ringan dalam bahasa Go) tertidur. Artikel ini akan menerangkan sebab ralat ini berlaku dan menyediakan penyelesaian.

Kandungan soalan

Ini ialah kod - pengeluar dan berbilang pengguna dalam rutin pergi. Pengeluar menyuntik maklumat ke dalam saluran, dan berbilang pengguna (masing-masing melalui rutin harian) harus membacanya secara selari.

func main() {
    alphabetArray := []string{"A", "B", "C"}

    alphabetChannel := make(chan string, 3)
    // producer.
    go func() {
        for _, alphabet := range alphabetArray {
            alphabetChannel <- alphabet
        }
    }()

    var wg sync.WaitGroup
    // spawn 10 consumers, consumers represented as a go-routine.
    for idx := 0; idx < 10; idx++ {
        wg.Add(1)
        go func() {
            for alphabet := range alphabetChannel {
                fmt.Println(alphabet)
            }
        }()
    }
    wg.Wait()
}

Berikut ialah pautan ke taman permainan - https://go.dev/play/p/yndataeexpb

Ralat yang saya terima ialah ini -

Satu Kedua c Ralat maut: semua goroutine sedang tidur - kebuntuan!

Penyelesaian

Tutup saluran apabila pengeluar selesai supaya pengguna tahu bila hendak berhenti:

go func() {
        defer close(alphabetchannel)
        for _, alphabet := range alphabetarray {
            alphabetchannel <- alphabet
        }
    }()

Beritahu kumpulan menunggu apabila pengguna selesai:

go func() {
            defer wg.Done()
            for alphabet := range alphabetChannel {
                fmt.Println(alphabet)
            }
        }()

Atas ialah kandungan terperinci Mengapa saya mendapat - goroutine adalah ralat tidur kerana isu pengguna pengeluar. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!

Kenyataan:
Artikel ini dikembalikan pada:stackoverflow.com. Jika ada pelanggaran, sila hubungi admin@php.cn Padam