Bagaimana untuk Mengelakkan Kebuntuan Apabila Mengumpul Hasil daripada Goroutines dalam Go?

Menggunakan Goroutines untuk Memproses Nilai dan Mengumpul Hasil Menjadi Sekeping

Goroutines ialah konsep asas dalam Go untuk pengaturcaraan serentak. Mereka membenarkan anda melaksanakan berbilang tugas secara serentak tanpa menyekat utas utama. Walau bagaimanapun, menggunakan gorouti boleh menjadi rumit, terutamanya apabila ia datang untuk mengumpulkan hasil daripada berbilang gorouti.

Pernyataan Masalah

Seorang pembangun cuba menggunakan gorouti untuk memproses senarai item dan kumpulkan nilai yang diproses menjadi kepingan. Walau bagaimanapun, mereka menghadapi yang digeruni "semua goroutine sedang tidur - kebuntuan!" ralat.

Punca Kebuntuan

Kebuntuan berlaku kerana kod sedang menunggu semua goroutine selesai diproses sebelum cuba mengumpul keputusan. Ini mewujudkan situasi di mana goroutin sedang menunggu hirisan tersedia untuk ditulis, sementara utas utama sedang menunggu goroutin selesai diproses.

Penyelesaian

Untuk menyelesaikan kebuntuan, adalah perlu untuk memperkenalkan penutupan tak segerak bagi saluran yang digunakan untuk berkomunikasi antara goroutine dan benang utama. Kod yang diubah suai di bawah menunjukkan penyelesaian:

// ...

// Create a channel to receive the processed values
sampleChan := make(chan sample)

var wg sync.WaitGroup

// Process each item in the list with a goroutine
for i, line := range contents {
    wg.Add(1)
    go func(line string) {
        defer wg.Done()
        // Process the item and send the result on the channel
        sampleChan <- newSample(line, *replicatePtr, *timePtr)
    }(line)
}

// Asyncronously close the channel when all goroutines are done
go func() {
    wg.Wait()
    close(sampleChan)
}()

// Read from the channel and gather results into a slice
var sampleList []sample
for s := range sampleChan {
    sampleList = append(sampleList, s)
}

// ...

Dengan menutup saluran secara tidak segerak, utas utama boleh meneruskan pengumpulan hasil walaupun semasa goroutin masih diproses. Ini memecahkan kebuntuan dan membenarkan kod untuk dilaksanakan dengan betul.

Pertimbangan Tambahan

Perlu diingat bahawa walaupun penyelesaian ini menyelesaikan kebuntuan, ia bukanlah penyelesaian yang lengkap untuk menguruskan konkurensi dalam senario khusus ini. Bergantung pada keperluan dan bilangan goroutine, penyegerakan tambahan dan mekanisme pengendalian ralat mungkin diperlukan untuk memastikan kebolehpercayaan dan ketepatan kod.

Atas ialah kandungan terperinci Bagaimana untuk Mengelakkan Kebuntuan Apabila Mengumpul Hasil daripada Goroutines dalam Go?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!