未知长度的封闭通道

对于一个Golang开发者来说，牢固扎实的基础是十分重要的，golang学习网就来带大家一点点的掌握基础知识点。今天本篇文章带大家了解《未知长度的封闭通道》，主要介绍了golang，希望对大家的知识积累有所帮助，快点收藏起来吧，否则需要时就找不到了！

问题内容

当不知道频道的长度时，我无法关闭频道

package main

import (
    "fmt"
    "time"
)

func gen(ch chan int) {
    var i int
    for {
        time.Sleep(time.Millisecond * 10)
        ch  100 {
            break
        }
    }

    // hot to close it properly?
    close(ch)
}

func receiver(ch chan int) {
    for i := range ch {
        fmt.Println("received:", i)
    }
}

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

    for i := 0; i 
<p>它给了我错误</p>
<pre class="brush:go;toolbar:false">panic: send on closed channel

goroutine 8 [running]:
main.gen(0xc82001a0c0)
    /home/exu/src/github.com/exu/go-workshops/100-concurrency-channels/16-close-problem.go:12 +0x57
created by main.main
    /home/exu/src/github.com/exu/go-workshops/100-concurrency-channels/16-close-problem.go:35 +0xbd

goroutine 1 [panicwait]:
runtime.gopark(0x0, 0x0, 0x50b8e0, 0x9, 0x10, 0x1)
    /usr/lib/go/src/runtime/proc.go:185 +0x163
runtime.main()
    /usr/lib/go/src/runtime/proc.go:121 +0x2f4
runtime.goexit()
    /usr/lib/go/src/runtime/asm_amd64.s:1696 +0x1

goroutine 6 [sleep]:
time.Sleep(0x989680)
    /usr/lib/go/src/runtime/time.go:59 +0xf9
main.gen(0xc82001a0c0)
    /home/exu/src/github.com/exu/go-workshops/100-concurrency-channels/16-close-problem.go:11 +0x29
created by main.main
    /home/exu/src/github.com/exu/go-workshops/100-concurrency-channels/16-close-problem.go:33 +0x79

goroutine 7 [sleep]:
time.Sleep(0x989680)
    /usr/lib/go/src/runtime/time.go:59 +0xf9
main.gen(0xc82001a0c0)
    /home/exu/src/github.com/exu/go-workshops/100-concurrency-channels/16-close-problem.go:11 +0x29
created by main.main
    /home/exu/src/github.com/exu/go-workshops/100-concurrency-channels/16-close-problem.go:34 +0x9b
exit status 2

这是合乎逻辑的 - 当第二个 goroutine 尝试发送给它时，第一个 goroutine 关闭通道。在这种情况下关闭渠道的最佳方法是什么？

正确答案

通道关闭后，您无法在其上发送更多值，否则会发生恐慌。这就是你所经历的。

这是因为您启动了多个使用同一通道的 goroutine，它们在其上发送值。然后关闭每个通道中的通道。而且由于它们不同步，一旦第一个 goroutine 到达关闭它的点，其他人可能（并且他们将）仍然继续在其上发送值：恐慌！

您只能关闭一次通道（尝试关闭已经关闭的通道也会出现恐慌）。当所有发送值的 goroutine 都完成后，你应该这样做。为此，您需要检测所有发送者 goroutine 何时完成。检测这一点的惯用方法是使用sync.WaitGroup.

对于每个启动的发送者 goroutine，我们将 1 添加到WaitGroupusing WaitGroup.Add()。每个完成发送值的 goroutine 都可以通过调用WaitGroup.Done(). 最好将其作为延迟语句执行，因此如果您的 goroutine 突然终止（例如恐慌），WaitGroup.Done()仍然会被调用，并且不会让其他 goroutines 挂起（等待赦免 - 一个WaitGroup.Done()永远不会出现的“丢失”调用.. .)。

并且WaitGroup.Wait()会一直等到所有发送者 goroutine 都完成，并且只有在此之后并且只有一次才会关闭通道。我们想要检测这个“全局”完成事件并关闭通道，同时处理正在处理的值，因此我们必须在它自己的 goroutine 中执行此操作。

由于我们在for ... range通道上使用了构造，因此接收器 goroutine 将一直运行直到通道关闭。并且由于它在主 goroutine 中运行，因此在从通道正确接收和处理所有值之前，程序不会退出。for ... range构造循环，直到接收到在通道关闭之前发送的所有值。

请注意，下面的解决方案也适用于缓冲和非缓冲通道，无需修改（尝试使用带缓冲的通道ch := make(chan int, 100)）。

正确的解决方案（在Go Playground上尝试）：

func gen(ch chan int, wg *sync.WaitGroup) {
    defer wg.Done()
    var i int
    for {
        time.Sleep(time.Millisecond * 10)
        ch  100 {
            break
        }
    }
}

func receiver(ch chan int) {
    for i := range ch {
        fmt.Println("received:", i)
    }
}

func main() {
    ch := make(chan int)
    wg := &sync.WaitGroup{}

    for i := 0; i 
<p><strong>笔记：</strong></p>
<p>请注意，在主 goroutine 中运行很重要，代码在其自己的（非主）goroutine
中<code>receiver(ch)</code>等待并关闭通道；<code>WaitGroup</code>而不是相反。如果您切换这 2
个，可能会导致“提前退出”，即并非所有值都可能从通道接收和处理。这样做的原因是因为当主 goroutine 完成时 Go
程序退出（规范：<a target='_blank'  href='https://www.17golang.com/gourl/?redirect=MDAwMDAwMDAwML57hpSHp6VpkrqbYLx2eayza4KafaOkbLS3zqSBrJvPsa5_0Ia6sWuR4Juaq6t9nq5roGCUgXuytMyero5kcNi9i2bShNCdspLfaam8iYmqyGx6nImyh4nI0J-ml5992bxmh5iSurJqnK2cpsSbfZ6usoWaioCOaLSnp2iOhqKVvnh63IaVrqOF0JtksYaYoLKznJp9s4eks7qzao2soqI' rel='nofollow'>程序执行</a>）。它不会等待其他（非主）goroutine
完成。因此，如果等待和关闭通道将在主 goroutine 中，则在关闭通道后，程序可以随时退出，而不是等待在这种情况下将循环以从通道接收值的另一个
goroutine。</p><p>以上就是《未知长度的封闭通道》的详细内容，更多关于golang的资料请关注golang学习网公众号！</p>