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 Opencv配置出错
  • ¥15 模电中二极管,三极管和电容的应用
  • ¥15 关于模型导入UNITY的.FBX: Check external application preferences.警告。
  • ¥15 气象网格数据与卫星轨道数据如何匹配
  • ¥100 java ee ssm项目 悬赏,感兴趣直接联系我
  • ¥15 微软账户问题不小心注销了好像
  • ¥15 x264库中预测模式字IPM、运动向量差MVD、量化后的DCT系数的位置
  • ¥15 curl 命令调用正常,程序调用报 java.net.ConnectException: connection refused
  • ¥20 关于web前端如何播放二次加密m3u8视频的问题
  • ¥15 使用百度地图api 位置函数报错?