登录
首页 >  Golang >  Go问答

未知长度的封闭通道

来源:Golang技术栈

时间:2023-03-03 19:11:34 166浏览 收藏

对于一个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 

它给了我错误

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 

笔记:

请注意,在主 goroutine 中运行很重要,代码在其自己的(非主)goroutine 中receiver(ch)等待并关闭通道;WaitGroup而不是相反。如果您切换这 2 个,可能会导致“提前退出”,即并非所有值都可能从通道接收和处理。这样做的原因是因为当主 goroutine 完成时 Go 程序退出(规范:程序执行)。它不会等待其他(非主)goroutine 完成。因此,如果等待和关闭通道将在主 goroutine 中,则在关闭通道后,程序可以随时退出,而不是等待在这种情况下将循环以从通道接收值的另一个 goroutine。

以上就是《未知长度的封闭通道》的详细内容,更多关于golang的资料请关注golang学习网公众号!

声明:本文转载于:Golang技术栈 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>