从 goroutine 中的缓冲通道读取时的执行顺序

偷偷努力，悄无声息地变强，然后惊艳所有人！哈哈，小伙伴们又来学习啦~今天我将给大家介绍《从 goroutine 中的缓冲通道读取时的执行顺序》，这篇文章主要会讲到等等知识点，不知道大家对其都有多少了解，下面我们就一起来看一吧！当然，非常希望大家能多多评论，给出合理的建议，我们一起学习，一起进步！

我在研究并发和缓冲通道时遇到了以下让我感到困惑的问题： https://play.golang.org/p/wir7wp2u-yf

1. 为什么函数 echo 中的通道（大小为 3）会在包含 4 的情况下“卸载”？

2. 为什么向通道发送5后，通道c的容量仍为0？

3. 为什么 10 没有回显？

package main

import "fmt"

func echo(c chan int) {
    for num := range c {
        //fmt.Printf("length of channel c: %v\n",len(c))
        fmt.Println(num)
    }
    fmt.Println("Done iterating")
}

func main() {
    fmt.Println("main() started")
    c := make(chan int, 3)

    go echo(c)

    c <- 1
    fmt.Printf("After 1, capacity %v\n",len(c))
    c <- 2
    fmt.Printf("After 2, capacity %v\n",len(c))
    c <- 3
    fmt.Printf("After 3, capacity %v\n",len(c))
    c <- 4 // blocks here
    fmt.Printf("After 4, capacity %v\n",len(c))
    c <- 5
    fmt.Printf("After 5, capacity %v\n",len(c))
    c <- 6
    fmt.Printf("After 6, capacity %v\n",len(c))
    c <- 7
    fmt.Printf("After 7, capacity %v\n",len(c))
    c <- 8
    fmt.Printf("After 8, capacity %v\n",len(c))
    c <- 9
    fmt.Printf("After 9, capacity %v\n",len(c))
    c <- 10
    fmt.Printf("After 10\n")
    fmt.Println("main() stopped")
}

解决方案

这完全取决于操作系统调度。上述代码的结果并不总是相同。

main() started
after 1, capacity 1
after 2, capacity 2
after 3, capacity 3
1
2
3
4
after 4, capacity 0
after 5, capacity 0
after 6, capacity 1
after 7, capacity 2
after 8, capacity 3
5
6
7
8
9
after 9, capacity 0
after 10
main() stopped

这个结果可能与您在演示中看到的结果相同。但是，这是不可预测的，因为我们无法确定操作系统如何调度 goroutine 的执行顺序。

如果我在本地计算机上运行此代码，每次执行时都会有所不同。见下文：

第一次运行

main() started
after 1, capacity 1
after 2, capacity 1
after 3, capacity 2
1
2
3
4
after 4, capacity 3
after 5, capacity 0
5
after 6, capacity 0
after 7, capacity 1
after 8, capacity 2
after 9, capacity 3
6
7
8
9
10
after 10
main() stopped

第二次运行

main() started
after 1, capacity 1
after 2, capacity 2
1
2
3
after 3, capacity 2
after 4, capacity 0
4
5
after 5, capacity 1
after 6, capacity 0
after 7, capacity 1
after 8, capacity 2
6
7
8
9
after 9, capacity 3
after 10
main() stopped
10

所以你的问题的答案是

1. 接收通道（对于4）只是在主函数中的fmt.printf之前执行。每次执行可能会有所不同。在本地计算机上尝试一下。

2. 与1类似，只是由range在len(c)之前读取。

3. 主协程在从通道读取 10 之前退出。在这种情况下，您应该使用一些技术等待读取通道中的所有项目，例如时间休眠、等待同步包组或另一个通道。

您可以通过在要检查的行之间插入 time.sleep(time.second) 来查看该程序的工作原理。

例如，如果你在 fmt.println("main() stopped") 之前睡眠 1 秒，你总是可以看到 10 回显，因为主 goroutine 会等待一秒钟。 （1 秒足以从通道读取项目）

package main

import "fmt"
import "time"

func echo(c chan int) {
    for num := range c {
        fmt.Println(num)
    }
    fmt.Println("Done iterating")
}

func main() {
    fmt.Println("main() started")
    c := make(chan int, 3)

    go echo(c)

    c <- 1
    fmt.Printf("After 1, capacity %v\n",len(c))
    c <- 2
    fmt.Printf("After 2, capacity %v\n",len(c))
    c <- 3
    fmt.Printf("After 3, capacity %v\n",len(c))
    c <- 4 // blocks here
    fmt.Printf("After 4, capacity %v\n",len(c))
    c <- 5
    fmt.Printf("After 5, capacity %v\n",len(c))
    c <- 6
    fmt.Printf("After 6, capacity %v\n",len(c))
    c <- 7
    fmt.Printf("After 7, capacity %v\n",len(c))
    c <- 8
    fmt.Printf("After 8, capacity %v\n",len(c))
    c <- 9
    fmt.Printf("After 9, capacity %v\n",len(c))
    c <- 10
    fmt.Printf("After 10\n")
    time.Sleep(time.Second)
    fmt.Println("main() stopped")
}

本篇关于《从 goroutine 中的缓冲通道读取时的执行顺序》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于Golang的相关知识，请关注golang学习网公众号！