Go频道和延迟

目前golang学习网上已经有很多关于Golang的文章了，自己在初次阅读这些文章中，也见识到了很多学习思路；那么本文《Go频道和延迟》，也希望能帮助到大家，如果阅读完后真的对你学习Golang有帮助，欢迎动动手指，评论留言并分享~

我刚刚在 ubuntu 64 位环境上尝试使用 go 通道，并对以下程序生成的输出感到困惑。

我得到了输出： 0 1 2 3 退出

取消注释两行注释时的输出： 0 1 2 3 4 退出

请解释该行为。 tia。

package main

import (
"fmt"
    //"time"
)

func main() {
    ch := make(chan int)
    done := make(chan bool)
    go func() {
        for i := 0; i < 5; i++ {
            ch <- i
        }
                //time.Sleep(1 * time.Second)
        done <- false
    }()
    go func() {
        for {
            select {
            case message := <-ch:
                fmt.Println(message)
            case <-done:
                return
            }
        }
    }()
    <-done
    fmt.Println("Exit")
}

解决方案

您不需要等待两个 goroutine，并且仅通过 done 向 2 个接收者发送单个值，如果第二个接收者恰好是 main，则这将导致死锁。

使用 waitgroup 可以简化代码，并允许您轻松等待所需数量的 goroutine。 https://play.golang.org/p/MWknv_9AFKp

ch := make(chan int)
var wg sync.WaitGroup

wg.Add(1)
go func() {
    defer wg.Done()
    defer close(ch)
    for i := 0; i < 5; i++ {
        ch <- i
    }
}()

wg.Add(1)
go func() {
    defer wg.Done()
    for message := range ch {
        fmt.Println(message)
    }

}()

wg.Wait()
fmt.Println("Exit")

您的主线程正在等待 done，然后退出。同时，您的第一个 go 函数将 5 个值传送到 ch，然后发送到 done。

然后从主线程读取 done 中的值，并且恰好发生在第二个 go 函数从 ch 读取最后一个值之前。当它这样做时，它退出程序。

请注意，如果您的第二个线程确实碰巧同时从 done 和 done 读取数据，那么您的程序将会死锁，因为主线程永远不会在 done 上接收数据，并且所有正在运行的 go 线程都将被阻塞等待在频道上接收。

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