我有一個包含數千條記錄的 CSV 檔案。我在一個 goroutine 中處理每條記錄，我想在一個切片中收集處理記錄的所有結果，以便將它們寫在另一個檔案中。我的代碼的簡化版本是：
var wg sync.WaitGroup
func main() {
c := make(chan string, 1)
csvfile, err := os.Open("data.csv")
reader := csv.NewReader(bufio.NewReader(csvfile))
//...
for {
line, err := reader.Read()
// ...
wg.Add(1)
go processRecord(line, c)
}
//...
results := make([]string, 0)
for r := range c { // ERROR HERE: fatal error: all goroutines are asleep - deadlock!
results = append(results , r)
}
// write results to file
wg.Wait()
close(c)
}
func processRecord(data []string, c chan string) {
defer wg.Done()
// ...
c <- *result
}
在 for 回圈中，我得到了所有結果，但在得到最后一個結果后回圈繼續，我得到這個錯誤：
fatal error: all goroutines are asleep - deadlock!
這段代碼有什么問題？我在 SO 上嘗試了不同的 QA，但沒有任何成功。
uj5u.com熱心網友回復：
僅當通道關閉時，for 回圈才會終止。您在 for 回圈終止后關閉通道，因此出現死鎖。
您可以通過將 for 回圈放入 goroutine 來修復：
results := make([]string, 0)
done:=make(chan struct{})
go func() {
for r := range c {
results = append(results , r)
}
close(done)
}()
wg.Wait()
close(c)
<-done
// read results
uj5u.com熱心網友回復：
for r := range c { // ERROR HERE: fatal error: all goroutines are asleep - deadlock!
mutex.Lock()
results = append(results , r)
mutex.Unlock()
}
goroutines 睡著了 - 死鎖！因為它是同時寫的。使用 Mutex 可以處理這個例外
轉載請註明出處，本文鏈接：https://www.uj5u.com/net/422098.html
標籤：
下一篇：有雙倍時如何查看方法的接收者