需求: 模拟两个协程,分别循环打印字母A和B。
分析: 要实现两个协程之间的交替协作,就必须用到channel通信机制,而channel正好是同步阻塞的。
半开方式
首先我们用一个channel变量来控制两个goroutine的交替打印:
结果发现打印出了ABBAABBA...的效果。
也就是我们控制了开始的次序,但没有控制结束的次序,发生了并发不安全的情况。
其实半开模式也可以用于某些场景下,如: 两个goroutine,在条件控制下,交替打印奇偶数:
封闭方式
接下来我们使用两个channel变量来模拟goroutine循环体的互斥问题。
我们在循环体首尾都使用了阻塞独占模式,两个chan交替释放控制权,达到了安全的协程交互控制。
再看看下面的Demo,同样的原理:
缓冲模式
缓冲模式和封闭模式相似,只是封闭模式中,两个goroutine有明确的首尾角色。而缓冲模式的第一生产者交给了主协程,两个goroutine结构一样,轮式交换角色。
结论:
Channel的本质就是同步式的生产消费模式
补充:go 让N个协程交替打印1-100
今天遇到一道面试题,开启N个协程,并交替打印1-100如给定N=3则输出:
goroutine0: 0
goroutine1: 1
goroutine2: 2
goroutine0: 3
goroutine1: 4
面试时没答案,虽过后研究参考了一些网上方法,并记录下来,先上代码
1、第一个for循环创建chan
2、第二个for循环里的lastChan意思是,当前chan如果要打印数据,就必须得上一个chan打印完后才能打印。
这里假设N=2,chan索引为0,1,当索引1要输出,就阻塞到索引0的chan有数据为止,当自己打印完后往自己的chan中发送一个1,方便给依赖自己的chan 解除阻塞。
这里有个特殊的地方,当索引为0时,他的依赖索引chan就为chanQueue的长度-1,如果没有在创建Chan中的时候没有下面这一串代码就会造成死锁
以上为个人经验,希望能给大家一个参考,也希望大家多多支持服务器之家。如有错误或未考虑完全的地方,望不吝赐教。
原文链接:https://blog.csdn.net/Gusand/article/details/99442113