代码出现死锁的原因及解决方法

今日不肯埋头，明日何以抬头！每日一句努力自己的话哈哈~哈喽，今天我将给大家带来一篇《代码出现死锁的原因及解决方法》，主要内容是讲解等等，感兴趣的朋友可以收藏或者有更好的建议在评论提出，我都会认真看的！大家一起进步，一起学习！

为什么我的代码在从通道读取时会死锁（随后崩溃），我希望它在通道完全读取后在读取时阻塞，但不会崩溃。我知道这是一种死锁状态，因为没有人写入通道并读取通道上的块。

如何更改代码以读取所有频道内容，然后从 main 退出而不是崩溃。

go 演示： 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\n", <-news) 
        //crashes here after printing 0-9
    }

}

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

解决方案

程序死锁，因为通道上的主块接收并且没有其他 goroutine 发送到该通道。

使用这种方式读取所有频道内容然后退出main：main读取频道直到关闭； foo 写入所有值并关闭通道。

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\n", v)
    }

}

func foo(news chan int) {
    for i := 0; i < 10; i++ {
        fmt.printf("writing\n")
        news <- i
    }
    // close channel to indicate that no more values will be sent.
    close(news) 
}

Run it on the Playground。

要解释为什么会发生这种情况，您从恐慌中获得的错误消息会告诉您其要点：

fatal error: all goroutines are asleep - deadlock!

你不能让所有的 goroutine 等待其他 goroutine 做某事。在这种情况下，当运行 foo 的 goroutine 完成时，并且运行 main 的 goroutine 已收到发送到 news 通道的所有消息（0 到 9），您的程序只剩下一个 goroutine 等待接收 a 上的消息。通道永远不会再有消息发送给它，因为周围没有其他 goroutine 来执行此操作。

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《代码出现死锁的原因及解决方法》文章吧，也可关注golang学习网公众号了解相关技术文章。