您好, 欢迎来到 !    登录 | 注册 | | 设为首页 | 收藏本站

如何停止goroutine

如何停止goroutine

在意识到您的问题是关于将值发送到goroutine中的chan之前,我匆忙编写了此答案。 下面的方法可以与上面建议的其他chan一起使用,或者利用您已经拥有的chan双向的事实,您可以只使用一个

如果您的goroutine仅用于处理来自chan的项目,则可以使用内置的“ close”和特殊的通道接收表单。

就是说,一旦您在chan上发送完商品,就将其关闭。然后在您的goroutine内,您会为接收操作符获得一个额外的参数,该参数显示通道是否已关闭

这是一个完整的示例(waitgroup用于确保该过程继续进行,直到goroutine完成):

package main

import "sync"
func main() {
    var wg sync.WaitGroup
    wg.Add(1)

    ch := make(chan int)
    go func() {
        for {
            foo, ok := <- ch
            if !ok {
                println("done")
                wg.Done()
                return
            }
            println(foo)
        }
    }()
    ch <- 1
    ch <- 2
    ch <- 3
    close(ch)

    wg.Wait()
}
Go 2022/1/1 18:15:10 有376人围观

撰写回答


你尚未登录,登录后可以

和开发者交流问题的细节

关注并接收问题和回答的更新提醒

参与内容的编辑和改进,让解决方法与时俱进

请先登录

推荐问题


联系我
置顶