让go语言健壮地并发（三）

2021-07-13 11:30:37 阅读：206 来源： 互联网

标签：25 健壮 producer quit 打印 chan 并发 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

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

让go语言健壮地并发（三）