为了账号安全,请及时绑定邮箱和手机立即绑定

Go:致命错误:所有 goroutine 都处于睡眠状态 - 死锁

Go:致命错误:所有 goroutine 都处于睡眠状态 - 死锁

Go
莫回无 2022-01-04 10:16:39
我有一个文本文件,里面只有一行字。我想将所有这些单词分别存储在一个频道中,然后从频道中将它们全部提取出来并一一打印出来。我有以下代码:func main() {    f, _ := os.Open("D:\\input1.txt")    scanner := bufio.NewScanner(f)    file1chan := make(chan string)       for scanner.Scan() {        line := scanner.Text()        // Split the line on a space        parts := strings.Fields(line)        for i := range parts {               file1chan <- parts[i]        }        }    print(file1chan)}func print(in <-chan string) {    for str := range in {        fmt.Printf("%s\n", str)    }}但是当我运行它时,我收到以下错误:致命错误:所有 goroutine 都处于睡眠状态 - 死锁!goroutine 1 [chan send]: main.main()我尝试在网上查找它,但我仍然无法修复它。谁能告诉我为什么会发生这种情况以及我如何解决它?
查看完整描述

1 回答

?
凤凰求蛊

TA贡献1825条经验 获得超4个赞

您file1chan是无缓冲的,因此当您尝试通过该通道发送值时,它会永远阻塞,等待某人获取值。


您需要启动一个新的 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

}


func print(in <-chan string) {

    for str := range in {

        fmt.Printf("%s\n", str)

    }

}

这是缓冲版本,仅用于处理单个字符串:


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)

}


func print(in <-chan string) {

    for str := range in { // read all values until channel gets closed

        fmt.Printf("%s\n", str)

    }

}


查看完整回答
反对 回复 2022-01-04
  • 1 回答
  • 0 关注
  • 168 浏览
慕课专栏
更多

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信