Go例程中的神秘结束：通道在未到达close语句时关闭

各位小伙伴们，大家好呀！看看今天我又给各位带来了什么文章？本文标题是《Go例程中的神秘结束：通道在未到达close语句时关闭》，很明显是关于Golang的文章哈哈哈，其中内容主要会涉及到等等，如果能帮到你，觉得很不错的话，欢迎各位多多点评和分享！

我创建了以下简单程序来使用通道测试扇入扇出模式。它的作用是生成一些 go 例程来计算来自输入通道的数字的平方并将平方发送到输出通道。然后，所有输出通道将合并为一个通道，以在 main 中打印正方形。

func calculatesquare(in <-chan int) <-chan int {
    out := make(chan int)

    go func() {
       for num := range in {
           fmt.printf("receving num %v\n", num)
           out <- num * num
           fmt.printf("sending square %v\n", num * num)
       }
       fmt.println("closing out")
       close(out)
    }()

    return out
}

func fanout(in <-chan int, workercount int) []<-chan int {
    outs := make([]<-chan int, 0, workercount)

    for i := 0 ; i < workercount ; i++ {
        outs = append(outs, calculatesquare(in))
    }

    return outs
}

func fanin(outs []<-chan int) <-chan int {
    var wg sync.waitgroup

    merge := make(chan int)

    for _, out := range outs {
        wg.add(1)

        go func() {
            for result := range out {
                merge <- result
            }

            wg.done()
        }()
    }

    go func() {
        wg.wait()
        fmt.println("closing merge")
        close(merge)
    }()

    return merge
}

func main() {
    in := make(chan int)

    go func() {
        for i := 0 ; i < 4 ; i++ {
            fmt.printf("sending num %v\n", i)
            in <- i
        }
        close(in)
    }()

    outs := fanout(in, 5)
    merge := fanin(outs)

    for num := range merge {
        fmt.printf("final square %v\n", num)
    }
}

在 main 函数中，我将 4 个数字 0 -> 3 发送到输入通道中，我希望在控制台中看到打印的 4 个正方形。然而，当我运行该程序时，尽管输出有点波动，但我从未在控制台中看到打印出 4 个平方数。

下面是我看到的示例输出。

Sending num 0
Sending num 1
Sending num 2
Sending num 3
Closing out
Receving num 0
Receving num 1
Receving num 2
Sending square  4
Closing out
Receving num 3
Final square 4
Closing merge

如果有人能向我解释为什么打印了 receving num 1 但 sending square 1 永远不会出现，我将非常感激。另外，如果没有打印sending square 1，那么output通道是如何关闭的。我只看到 2 clos​​ing out，但是，我合并结果的等待组结束了它的 wait()。

我一定是在某个地方做错了什么。

正确答案

您的问题出在下面的代码中，fanin 函数中的 for 循环。

for _, out := range outs {
        wg.add(1)

        go func() {
            for result := range out {
                merge <- result
            }

            wg.done()
        }()
    }

原因是你在 gofunc 中使用了 out 迭代器变量，当 gofunc 要使用它时，循环就结束了。

这在 go/wiki/CommonMistakes 的子主题 在循环迭代器变量 上使用 goroutine 中进行了描述

更多示例 - 请阅读 this

更正后的循环应如下所示，

for _, out := range outs {
        wg.add(1)

        go func(c <- chan int) {
            for result := range c {
                merge <- result
            }

            wg.done()
        }(out)
    }

修复：

for _, out := range outs {
    wg.Add(1)

    out := out // <- add this

为什么？

https://golang.org/doc/effective_go 是一个优秀的资源，涵盖了 channels section 末尾的确切关闭错误（@jimb 提到的）：

今天带大家了解了的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~