多个 goroutine 退出等待无缓冲通道

各位小伙伴们，大家好呀！看看今天我又给各位带来了什么文章？本文标题是《多个 goroutine 退出等待无缓冲通道》，很明显是关于Golang的文章哈哈哈，其中内容主要会涉及到等等，如果能帮到你，觉得很不错的话，欢迎各位多多点评和分享！

我试图同时退出多个 goroutine。 根据 https://www.godesignpatterns.com/2014/04/exiting-multiple-goroutines-simultaneously.html 有一个明确定义的方法来做到这一点。

我看到的另一种方法如下

package main

import (
    "fmt"
    "time"
)

func main() {
    var inCh chan int = make(chan int, 100)
    var exit chan bool = make(chan bool)

    for i := 0; i < 20; i++ {
        go func(instance int) {
            fmt.Println("In go routine ", instance)
            for {
                select {
                case <-exit:
                    fmt.Println("Exit received from ", instance)
                    exit <- true
                    return
                case value := <-inCh:
                    fmt.Println("Value=", value)
                }
            }
        }(i)
    }

    time.Sleep(1 * time.Second)

    exit <- true
    <-exit   // Final exit
    fmt.Println("Final exit")
}

但是我很困惑，我真的不明白为什么最后的无缓冲通道作为最后一条语句执行。 实际上，我有 20 个 go 例程监听出口通道。随机一个人会收到它并将其发送给另一个人。 为什么总是在 go 例程中进行接收，并且只有当所有例程都完成时，带有注释“// final exit”的通道接收才会执行？

如果有人能给我一个解释，我将非常感激。

正确答案

考虑这个轻微的修改。

package main

import (
    "fmt"
)

func main() {
    var exit chan int = make(chan int)
        var workers = 20
    for i := 0; i < workers; i++ {
        go func(instance int) {
            fmt.println("in go routine ", instance)
            for {
                select {
                case i := <-exit:
                    fmt.println("exit", i, "received from ", instance)
                    exit <- i-1
                    return
                }
            }
        }(i)
    }
    exit <- workers
    fmt.println("final exit:", <-exit)
}

在这里，我做了三件事：首先，为了简洁起见，我删除了未使用的通道。其次，我取消了睡眠。第三，我将 exit 通道更改为 int 通道，每次传递都会递减。如果我传递工作人员数量，则“最终”消息中除 0 之外的任何值都表示已删除工作人员。

这是一个运行示例：

% go run t.go
In go routine  8
In go routine  5
In go routine  0
In go routine  2
Exit 20 received from  8
Exit 19 received from  5
Final exit: 18
In go routine  13

当 main 调用 time.sleep 时，在睡眠结束之前不会安排它。其他 goroutine 都有这个时间来设置它们的通道读取器。我只能假设，因为我在任何地方都找不到它，所以通道读取器可能会以大致时间顺序错误的方式排队 - 因此，sleep 保证 main 的读取器是最后一个。

如果这是一致的行为，那么它肯定不可靠。

有关此问题的更多想法，请参阅 Multiple goroutines listening on one channel。

使用 close() 进行取消，如链接文章中所示。

不保证有问题的代码能够正常工作。这是失败的场景：

1. 一个 goroutine 已准备好从 exit 接收。所有其他 goroutine 都在其他地方忙碌。
2. main 发送的值被就绪 goroutine 接收。
3. 该 goroutine 向 exit 发送一个值，该值由 main() 接收。

其他 goroutine 不会退出，因为没有更多值发送到 exit。请参阅 this playground example，它使用 time.seep 来归纳问题场景。

程序的执行就像通道维护一个等待 goroutine 的有序队列一样，但规范中没有任何内容保证这种行为。即使通道具有有序队列，如果 goroutine 正在执行除等待 exit 接收之外的其他操作，程序也可能会遇到上述情况。

今天关于《多个 goroutine 退出等待无缓冲通道》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！