如何停止goroutine

如何停止goroutine,第1张

如何停止goroutine

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

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

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

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

package mainimport "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()}


欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/zaji/4921692.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-11-12
下一篇 2022-11-12

发表评论

登录后才能评论

评论列表(0条)

保存