Go:致命错误“所有 Goroutine 都处于睡眠状态 - 死锁”解释
在 Go 中,发送到无缓冲通道会阻塞发送者,直到接收器可用。在提供的代码中,负责向 file1chan 通道发送单词的 goroutine 是唯一的 goroutine,并且没有接收者。因此,发送者被无限期地阻塞,导致死锁。
使用新 Goroutine 的解决方案:
一种解决方案是创建一个单独的 Goroutine 来处理发送字。这个goroutine不会阻塞主goroutine并允许并发执行。
func main() { f, _ := os.Open("D:\input1.txt") scanner := bufio.NewScanner(f) file1chan := make(chan string) go func() { // start a new goroutine that sends strings down file1chan for scanner.Scan() { line := scanner.Text() // Split the line on a space parts := strings.Fields(line) for i := range parts { file1chan <- parts[i] } } close(file1chan) }() print(file1chan) // read strings from file1chan }
使用缓冲通道的解决方案:
另一种解决方案是创建一个缓冲通道,它允许同时发送和接收多个值。对于给定的问题,缓冲区大小为 1 就足够了。
func main() { f, _ := os.Open("D:\input1.txt") scanner := bufio.NewScanner(f) file1chan := make(chan string, 1) // buffer size of one for scanner.Scan() { line := scanner.Text() // Split the line on a space parts := strings.Fields(line) for i := range parts { file1chan <- parts[i] } } close(file1chan) // we're done sending to this channel now, so we close it. print(file1chan) }
以上是如何解决 Go 中的'All Goroutines Are Asleep - Deadlock”错误?的详细内容。更多信息请关注PHP中文网其他相关文章!