go - 如何确保按 channel 生产和消费数据是安全的

Question

我是golang的新手，这是我的目的，我想让2个例程与一个公共(public) channel 同时运行，消费者应该在 channel 创建后启动并始终获取数据直到 channel 关闭，我的代码模板如下:

var userChannel chan string
for index := 0; index < *clientNums; index++ {
        wg.Add(1)
        go run1()
        go run2()
    }
    wg.Wait()

}

func run1() {
   defer wg.Done()
   // ...some logic
   userChannel = make(chan string, *readUserNums)
   for index := 0; index < *readUserNums; index++ {
         //...some logic
         userChannel <- userId
         //...some logic

   }
   close(userChannel)
}
func run2() {
   for sendId := range userChannel {
       //...some logic
}
}

在我的代码中，如果 run2首先运行它会 panic ，因为尚未创建 channel 并且 channel 中没有数据。我怎样才能达到我的目的？谢谢你

Answer 1

首先创建 channel ，然后将其传递到您的 goroutines 中，而不是将其存储在全局中并动态创建它。