我在 goroutine 中使用通道时遇到问题。
var test = make(chan string)
func main() {
go initChan()
for i := 0; i < 2; i++ {
go readChan()
}
var input string
fmt.Scanln(&input)
}
func initChan() {
for i := 0; i < 100; i++ {
test <- "Iteration num: " + strconv.Itoa(i)
time.Sleep(time.Second * 5)
}
}
func readChan() {
for {
message := <- test
log.Println(message)
}
}
输出:
2019/12/24 08:21:17 Iteration num: 0
2019/12/24 08:21:22 Iteration num: 1
2019/12/24 08:21:27 Iteration num: 2
2019/12/24 08:21:32 Iteration num: 3
2019/12/24 08:21:37 Iteration num: 4
2019/12/24 08:21:42 Iteration num: 5
................................
我需要线程读取而不等待测试变量的更新。现在每个 readChan() 都在等待 initChan() 更新测试变量。
是否可以使 readChan() 线程一次工作而无需等待每个线程的 initChan() ?
冉冉说
陪伴而非守候
相关分类