将无缓冲通道更改为缓冲通道会导致 goroutine 阻塞

小伙伴们对Golang编程感兴趣吗？是否正在学习相关知识点？如果是，那么本文《将无缓冲通道更改为缓冲通道会导致 goroutine 阻塞》，就很适合你，本篇文章讲解的知识点主要包括。在之后的文章中也会多多分享相关知识点，希望对大家的知识积累有所帮助！

这是一个在 goroutine 中使用通道和选择的练习。如果断开连接通道更改为缓冲通道，则 goroutine 根本不会运行。

为什么从无缓冲通道更改为缓冲通道会阻止 goroutine 运行？

func selectdemo(wg *sync.waitgroup) {

    messagech := make(chan int, 10)
    disconnectch := make(chan struct{})
    //  go routine won't run if channel is buffered
    //disconnectch := make(chan struct{}, 1)

    defer close(messagech)
    defer close(disconnectch)
    go func() {
        fmt.println("  goroutine")
        wg.add(1)
        for {
            select {
            case v := <-messagech:
                fmt.println(v)
            case <-disconnectch:
                fmt.println("  disconnectch")
                //  empty the buffered channel before exiting
                for {
                    select {
                    case v := <-messagech:
                        fmt.println(v)
                    default:
                        fmt.println("  disconnection, return")
                        wg.done()
                        return
                    }
                }
            }
        }
    }()

    fmt.println("sending ints")
    for i := 0; i < 10; i++ {
        messagech <- i
    }

    fmt.println("sending done")
    disconnectch <- struct{}{}
}

这是从 main 调用该函数的代码。我使用等待组来确保 goroutine 在程序退出之前完成：

wg := sync.WaitGroup{}
ch09.SelectDemo(&wg)
wg.Wait()

正确答案

该代码逻辑有很多缺陷 - 其中一些是：
1- 由于 messagech 已被缓冲，因此此代码不会阻塞：

for i := 0; i < 10; i++ {
        messagech <- i
    }

所以下一个代码是在快速路径中运行：

disconnectch <- struct{}{}

如果您对 disconnectch 进行缓冲，则该行也不会阻塞运行，并且 selectdemo 函数在运行 wg.add(1) 之前可能退出。 p>

所以：你必须输入：

wg.add(1)

之前

go func() {

2- 即使在 go func() 之前使用 wg.add(1) { code -
你有：

defer close(messagech)
    defer close(disconnectch)

这将在 selectdemo 函数返回时关闭两个通道 这个 select 是一个随机选择，因为两个通道都已准备好：

fmt.println("  goroutine")
        for {
            select {
            case v := <-messagech:
                fmt.println(v)
            case <-disconnectch:

第二个选择极有可能：

for {
                    select {
                    case v := <-messagech:
                        fmt.println(v)
                    default:
                        fmt.println("  disconnection, return")
                        wg.done()
                        return
                    }
                }

自 messagech 关闭后将永远运行，在读取通道数据后永远返回 0：

case v := <-messagech:
    fmt.println(v)

程序执行速度快

访问网址：https://pkg.go.dev/sync#WaitGroup.Add

请注意，计数器为零时发生的具有正增量的调用必须在等待之前发生。具有负增量的调用或在计数器大于零时开始的具有正增量的调用可能随时发生。 通常这意味着对 add 的调用应该在创建 goroutine 或其他要等待的事件的语句之前执行。如果重复使用 waitgroup 来等待多个独立的事件集，则新的 add 调用必须在创建 goroutine 或其他要等待的事件之前执行。之前的所有 wait 调用均已返回。请参阅 waitgroup 示例。

func SelectDemo(wg *sync.WaitGroup) {

    messageCh := make(chan int, 10)
    disconnectCh := make(chan struct{}, 1)
    //  go routine won't run if channel is buffered
    //disconnectCh := make(chan struct{}, 1)

    wg.Add(1)

    defer close(messageCh)
    defer close(disconnectCh)
    go func() {
        fmt.Println("  goroutine")
        for {
            select {
            case v := <-messageCh:
                fmt.Println(v)
            case <-disconnectCh:
                fmt.Println("  disconnectCh")
                //  empty the buffered channel before exiting

                fmt.Println("  disconnection, return")
                wg.Done()
                return
            }
        }
    }()

    fmt.Println("Sending ints")
    for i := 0; i < 10; i++ {
        messageCh <- i
    }

    //Delay sending exit signal
    time.Sleep(3 * time.Second)

    fmt.Println("Sending done")
    disconnectCh <- struct{}{}
}

我修改了你的代码

再试一次！！！

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于Golang的相关知识，也可关注golang学习网公众号。