登录
首页 >  Golang >  Go问答

关于主例程和子例程同时收听同一频道的问题

来源:stackoverflow

时间:2024-04-14 11:42:36 420浏览 收藏

在Golang实战开发的过程中,我们经常会遇到一些这样那样的问题,然后要卡好半天,等问题解决了才发现原来一些细节知识点还是没有掌握好。今天golang学习网就整理分享《关于主例程和子例程同时收听同一频道的问题》,聊聊,希望可以帮助到正在努力赚钱的你。

问题内容

func main() {
    c := make(chan os.Signal, 1)
    signal.Notify(c)

    ticker := time.NewTicker(time.Second)
    stop := make(chan bool)

    go func() {
        defer func() { stop <- true }()
        for {
            select {
            case <-ticker.C:
                fmt.Println("Tick")
            case <-stop:
                fmt.Println("Goroutine closing")
                return
            }
        }
    }()

    <-c
    ticker.Stop()

    stop <- true

    <-stop
    fmt.Println("Application stopped")
}

无论我运行上面的代码多少次,我都会得到相同的结果。也就是说,在我按 ctrl+c 后,“goroutine opening”总是在“application stopped”之前打印。

我认为,理论上,“goroutine opening”有可能根本不会被打印。我对吗?不幸的是,我从未得到这个理论结果。

顺便说一句:我知道应该避免在一个例程中读写通道。暂时忽略它。


解决方案


在您的情况下, goroutine opening 将始终被执行,并且它始终会在 application stop 之前打印,因为您的 stop 通道没有缓冲。这意味着发送将阻塞,直到收到结果。

在您的代码中,main 中的 stop <- true 将阻塞,直到 goroutine 收到该值,从而导致通道再次为空。然后,main 中的 <-stop 将阻塞,直到另一个值发送到通道,这会在您的 goroutine 在打印 goroutine 关闭 之后返回时发生。

如果您以缓冲方式初始化频道

stop := make(chan bool, 1)

那么关闭的goroutine可能不会被执行。要看到这一点,您可以在打印 tick 后立即添加 time.Sleep,因为这使得这种情况更有可能发生(每次在睡眠期间按 ctrl+c 时都会发生这种情况)。

使用 sync.WaitGroup 等待 goroutine 完成是一种不错的选择,特别是当您必须等待多个 goroutine 时。您还可以使用 context.Context 来停止 goroutine。重新编写代码以使用这两种方法可能如下所示:

func main() {
    c := make(chan os.Signal, 1)
    signal.Notify(c)

    ticker := time.NewTicker(time.Second)
    ctx, cancel := context.WithCancel(context.Background())
    var wg sync.WaitGroup

    wg.Add(1)
    go func() {
        defer func() { wg.Done() }()
        for {
            select {
            case <-ctx.Done():
                fmt.Println("Goroutine closing")
                return
            case <-ticker.C:
                fmt.Println("Tick")
                time.Sleep(time.Second)
            }
        }
    }()

    <-c
    ticker.Stop()

    cancel()

    wg.Wait()

    fmt.Println("Application stopped")
}

文中关于的知识介绍,希望对你的学习有所帮助!若是受益匪浅,那就动动鼠标收藏这篇《关于主例程和子例程同时收听同一频道的问题》文章吧,也可关注golang学习网公众号了解相关技术文章。

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