Bagaimana untuk Mengelakkan Kebuntuan Apabila Mengumpul Hasil daripada Goroutines?

Menggunakan Goroutines untuk Pemprosesan Data

Dalam Go, goroutine ialah utas ringan yang membolehkan pelaksanaan tugasan serentak. Apabila bekerja dengan goroutine, adalah penting untuk mengumpul hasil dengan betul selepas pemprosesan untuk mengelakkan kebuntuan.

Pernyataan Masalah

Pertimbangkan coretan kod berikut:

sampleChan := make(chan sample)
var wg sync.WaitGroup

// Read from contents list
for i, line := range contents {
    wg.Add(1)
    // Process each item with a goroutine and send output to sampleChan
    go newSample(line, *replicatePtr, *timePtr, sampleChan, &wg)
}
wg.Wait()

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

Kod ini cuba memproses item dalam senarai menggunakan goroutine dan mengumpulkan hasilnya menjadi kepingan. Walau bagaimanapun, ia menghadapi ralat kebuntuan kerana saluran ditutup sebelum keputusan dikumpulkan.

Penyelesaian

Untuk menyelesaikan isu ini, kami boleh menutup saluran secara tidak segerak. pekerja telah selesai memproses. Berikut ialah kod yang diperbetulkan:

for i, line := range contents {
    wg.Add(1)
    // Process each item with a goroutine and send output to sampleChan
    go newSample(line, *replicatePtr, *timePtr, sampleChan, &wg)
}

go func() {
    wg.Wait()
    close(sampleChan)
}()

for s := range sampleChan {
  ..
}

Kod ini memulakan goroutine yang memproses item dan menghantar hasil kepada sampleChan. Pada masa yang sama, ia juga memulakan goroutine lain yang menunggu semua pekerja selesai dan kemudian menutup saluran. Ini memastikan bahawa semua keputusan dikumpul sebelum saluran ditutup.

Penyelesaian Alternatif

Untuk kebolehbacaan dan kebolehujian kod yang lebih baik, disyorkan untuk menggunakan fungsi dan pengendalian newSample yang segerak konkurensi dalam goroutine utama.

for i, line := range contents {
    wg.Add(1)
    go func(line string) {
        defer wg.Done()
        sampleChan <- newSample(line, *replicatePtr, *timePtr)
    }(line)
}

Pendekatan ini mengekalkan primitif konkurensi setempat, memudahkan penyelenggaraan kod dan mengurangkan risiko ralat.

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