编辑: 在意识到您的问题是关于将值发送到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()}
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)