让go语言健壮地并发(三)
作者:互联网
package main
import (
"fmt"
"runtime"
)
func producer(ch chan int, quit chan bool) {
i := 1
for {
select {
case <-quit:
close(ch)
fmt.Println("quit")
return
default:
ch <- i
i++
}
}
}
func init() {
runtime.GOMAXPROCS(4)
}
func main() {
ch := make(chan int)
quit := make(chan bool)
go producer(ch, quit)
for num := range ch {
if num >= 25 {
quit <- true
close(quit)
}
fmt.Println("num=", num)
}
fmt.Println("game over!")
}
这是我们上一节的代码,今天加了一个init函数,也可以去掉,对我们的测试目的影响不大。
多次运行后,看看发生了什么后果
程序完全锁死,根本出不来,我们要求的是要把25打印出来,没有打印;我们要求子协程在退出的时候打印“quit”,也没有打印出来,我是通过ctrl+c中断程序的运行。
我们来看看正常的退出应该是什么样的
也就是说这个程序并发并不稳定,什么原因呢?应该是最后一次和发生了资源冲突。怎么解决这个问题呢?我修改主协程的输出,抛弃最后一次的输出,看代码。
package main
import (
"fmt"
"runtime"
)
func producer(ch chan int, quit chan bool) {
i := 1
for {
select {
case <-quit:
close(ch)
fmt.Println("quit")
return
default:
ch <- i
i++
}
}
}
func init() {
runtime.GOMAXPROCS(4)
}
func main() {
ch := make(chan int)
quit := make(chan bool)
go producer(ch, quit)
for num := range ch {
if num > 25 {
quit <- true
close(quit)
break
}
fmt.Println("num=", num)
}
fmt.Println("game over!")
}
连续运行10多次,都没有问题。看样子问题基本得到了解决。当然还有其他的方式。
在这里我真的有点怀疑, golang的并发真的是最好的设计吗?为啥不能有效避免这么多的坑呢?希望google在后续的版本能改进一下。
标签:25,健壮,producer,quit,打印,chan,并发,go 来源: https://blog.csdn.net/qq_37220984/article/details/118695258