Bagaimanakah Goroutine dengan Gelung Infinite Boleh Menghalang Goroutine Lain dalam Go?

Groutine Menyekat Orang Lain

Dalam Go, goroutine ialah urutan pelaksanaan yang ringan. Biasanya, goroutine boleh berjalan serentak tanpa menghalang satu sama lain. Walau bagaimanapun, dalam keadaan tertentu, satu goroutine boleh menyekat pelaksanaan yang lain.

Pertimbangkan kod berikut:

func main() {
    timeout := make(chan int)
    go func() {
        time.Sleep(time.Second)
        timeout <- 1
    }()

    res := make(chan int)
    go func() {
        for {
        }
        res <- 1
    }()
    select {
    case <-timeout:
        fmt.Println("timeout")
    case <-res:
        fmt.Println("res")
    }
}

Dalam contoh ini, goroutine dimulakan dengan gelung tak terhingga. Biasanya, goroutine ini tidak seharusnya menghalang goroutine lain daripada melaksanakan. Walau bagaimanapun, nampaknya goroutine pertama entah bagaimana menyekat goroutine kedua daripada dihantar ke saluran tamat masa.

Penjelasan

Tingkah laku ini adalah disebabkan oleh cara goroutine adalah dijadualkan dalam Go. Penjadualan koperasi digunakan, yang bermaksud bahawa goroutine mesti secara sukarela menghasilkan pelaksanaan kepada penjadual agar goroutine lain dapat dijalankan. Dalam kod yang disediakan, goroutine dengan gelung tak terhingga tidak pernah menghasilkan, yang menghalang goroutine yang lain daripada membuat kemajuan.

Groutine biasanya menghasilkan di bawah syarat berikut:

• Penghantaran saluran tanpa buffer /receive
• Panggilan sistem (cth., fail/rangkaian membaca/menulis)
• Peruntukan memori
• Masa.Sleep() dipanggil
• runtime.Gosched() dipanggil

Dalam kes ini , tiada syarat ini dipenuhi, jadi goroutine dengan gelung tak terhingga terus berjalan selama-lamanya.

Penyelesaian

Untuk menyelesaikan isu ini, terdapat beberapa penyelesaian yang mungkin:

• Gunakan penjadual preemptive. Ini sedang dalam proses, tetapi ia akan membenarkan gorout diganggu pada bila-bila masa, tidak kira sama ada ia mengalah.
• Gunakan saluran tidak buffer. Apabila menghantar ke saluran tidak buffer, penghantar akan menyekat sehingga goroutine lain sedia untuk menerima.
• Gunakan pemasa. Fungsi time.After() boleh digunakan untuk mencipta saluran yang akan menerima selepas tempoh tertentu. Dengan menghantar ke saluran ini, anda boleh memaksa goroutine untuk menghasilkan.
• Gunakan masa jalan.Gosched() dalam gelung tak terhingga. Ini secara eksplisit akan menghasilkan pelaksanaan kepada penjadual.

Penyelesaian terbaik untuk aplikasi khusus anda akan bergantung pada sifat goroutine dan tingkah laku yang diingini.

Atas ialah kandungan terperinci Bagaimanakah Goroutine dengan Gelung Infinite Boleh Menghalang Goroutine Lain dalam Go?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!