26. Go 语言中通道死锁经典错误案例详解

时间 2020-09-20

标签语言通道死锁经典错误案例详解繁體版

原文原文链接

Hi，你们好，我是明哥。git

在本身学习 Golang 的这段时间里，我写了详细的学习笔记放在个人我的微信公众号《Go编程时光》，对于 Go 语言，我也算是个初学者，所以写的东西应该会比较适合刚接触的同窗，若是你也是刚学习 Go 语言，不防关注一下，一块儿学习，一块儿成长。github

个人在线博客： http://golang.iswbm.com
个人 Github：github.com/iswbm/GolangCodingTime

刚接触 Go 语言的信道的时候，常常会遇到死锁的错误，而致使这个错误的缘由有不少种，这里整理了几种常见的。golang

fatal error: all goroutines are asleep - deadlock!

错误示例一

看下面这段代码编程

package main

import "fmt"

func main() {
    pipline := make(chan string)
    pipline <- "hello world"
    fmt.Println(<-pipline)
}

运行会抛出错误，以下数组

fatal error: all goroutines are asleep - deadlock!

看起来好像没有什么问题？先往信道中存入数据，再从信道中读取数据。微信

回顾前面的基础，咱们知道使用 make 建立信道的时候，若不传递第二个参数，则你定义的是无缓冲信道，而对于无缓冲信道，在接收者未准备好以前，发送操做是阻塞的.函数

所以，对于解决此问题有两种方法：学习

使接收者代码在发送者以前执行
使用缓冲信道，而不使用无缓冲信道

第一种方法：spa

若要程序正常执行，须要保证接收者程序在发送数据到信道前就进行阻塞状态，修改代码以下3d

package main

import "fmt"

func main() {
    pipline := make(chan string)
    fmt.Println(<-pipline)
    pipline <- "hello world"
}

运行的时候仍是报一样的错误。问题出在哪里呢？

原来咱们将发送者和接收者写在了同一协程中，虽然保证了接收者代码在发送者以前执行，可是因为前面接收者一直在等待数据而处于阻塞状态，因此没法执行到后面的发送数据。仍是同样形成了死锁。

有了前面的经验，咱们将接收者代码写在另外一个协程里，并保证在发送者以前执行，就像这样的代码

package main

func hello(pipline chan string)  {
    <-pipline
}

func main()  {
    pipline := make(chan string)
    go hello(pipline)
    pipline <- "hello world"
}

运行以后，一切正常。

第二种方法：

接收者代码必须在发送者代码以前执行，这是针对无缓冲信道才有的约束。

既然这样，咱们改使用可缓冲信道不就OK了吗？

package main

import "fmt"

func main() {
    pipline := make(chan string, 1)
    pipline <- "hello world"
    fmt.Println(<-pipline)
}

运行以后，一切正常。

错误示例二

每一个缓冲信道，都有容量，当信道里的数据量等于信道的容量后，此时再往信道里发送数据，就失形成阻塞，必须等到有人从信道中消费数据后，程序才会往下进行。

好比这段代码，信道容量为 1，可是往信道中写入两条数据，对于一个协程来讲就会形成死锁。

package main

import "fmt"

func main() {
    ch1 := make(chan string, 1)

    ch1 <- "hello world"
    ch1 <- "hello China"

    fmt.Println(<-ch1)
}

错误示例三

当程序一直在等待从信道里读取数据，而此时并无人会往信道中写入数据。此时程序就会陷入死循环，形成死锁。

好比这段代码，for 循环接收了两次消息（"hello world"和“hello China”）后，再也没有人发送数据了，接收者就会处于一个等待永远接收不到数据的囧境。陷入死循环，形成死锁。

package main

import "fmt"

func main() {
    pipline := make(chan string)
    go func() {
        pipline <- "hello world"
        pipline <- "hello China"
        // close(pipline)
    }()
    for data := range pipline{
        fmt.Println(data)
    }
}

包子铺里的包子已经卖完了，可还有人在排队等着买，若是再也不作包子，就要告诉排队的人：不用等了，今天的包子已经卖完了，明日请早呀。

不能让人家死等呀，不跟客人说明一下，人家还觉得大家店后面还在蒸包子呢。

因此这个问题，解决方法很简单，只要在发送完数据后，手动关闭信道，告诉 range 信道已经关闭，无需等待就行。

package main

import "fmt"

func main() {
    pipline := make(chan string)
    go func() {
        pipline <- "hello world"
        pipline <- "hello China"
        close(pipline)
    }()
    for data := range pipline{
        fmt.Println(data)
    }
}

系列导读

01. 开发环境的搭建（Goland & VS Code）

02. 学习五种变量建立的方法

03. 详解数据类型：整形与浮点型

04. 详解数据类型：byte、rune与string

05. 详解数据类型：数组与切片

06. 详解数据类型：字典与布尔类型

07. 详解数据类型：指针

08. 面向对象编程：结构体与继承

09. 一篇文章理解 Go 里的函数

10. Go语言流程控制：if-else 条件语句

11. Go语言流程控制：switch-case 选择语句