duanpu1064 2018-08-30 23:16
浏览 174
已采纳

为什么我的代码会死锁以及如何解决它

Why does my code deadlock (followed by crash) on read from channel, I would expect it to block on read after the channel is read completely, but not crash. I understand it is a deadlock state as no one is writing to the channel and read blocks on it.

How can I change the code to read all the channel content and then exit from main instead of crash.

Go playground: https://play.golang.org/p/rjXZZOx1FFZ

package main

import (
    "fmt"
    "sync"
)

func main() {
    var wg sync.WaitGroup
    news := make(chan int, 10)

    wg.Add(1)

    go foo(&wg, news) 

    wg.Wait()   

    for {
        fmt.Printf("reading: %v
", <-news) 
        //crashes here after printing 0-9
    }

}

func foo(wg *sync.WaitGroup, news chan int) {
    for i:=0; i<10;i++ {
        fmt.Printf("Writing
")
        news <- i
    }
    (*wg).Done()
}
  • 写回答

3条回答 默认 最新

  • doudun3040 2018-08-30 23:28
    关注

    The program deadlocks because main blocks on channel receive and there are no other goroutines that will send to that channel.

    Use this approach to read all the channel content and then exit from main: main reads the channel until closed; foo writes all values and closes the channel.

    func main() {
        news := make(chan int, 10)
        go foo(news)
        // range breaks when the channel is closed
        for v := range news { 
    
            fmt.Printf("reading: %v
    ", v)
        }
    
    }
    
    func foo(news chan int) {
        for i := 0; i < 10; i++ {
            fmt.Printf("Writing
    ")
            news <- i
        }
        // close channel to indicate that no more values will be sent.
        close(news) 
    }
    

    Run it on the Playground.

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(2条)

报告相同问题?

悬赏问题

  • ¥15 一个服务器已经有一个系统了如果用usb再装一个系统,原来的系统会被覆盖掉吗
  • ¥15 使用esm_msa1_t12_100M_UR50S蛋白质语言模型进行零样本预测时,终端显示出了sequence handled的进度条,但是并不出结果就自动终止回到命令提示行了是怎么回事:
  • ¥15 前置放大电路与功率放大电路相连放大倍数出现问题
  • ¥30 关于<main>标签页面跳转的问题
  • ¥80 部署运行web自动化项目
  • ¥15 腾讯云如何建立同一个项目中物模型之间的联系
  • ¥30 VMware 云桌面水印如何添加
  • ¥15 用ns3仿真出5G核心网网元
  • ¥15 matlab答疑 关于海上风电的爬坡事件检测
  • ¥88 python部署量化回测异常问题