40、状态协程
00 分钟
2022-8-26
在前面的例子中,我们用
39、互斥锁
进行了明确的锁定,来让共享的state跨多个Go协程同步访问。另一个选择是,使用内建协程和通道的同步特性来达到同样的效果。Go共享内存的思想是,通过通信使每个数据仅被单个协程所拥有,即通过通信实现共享内存。基于通道的方法与该思想完全一致。
 
 
 
 
 
 
 
在这里例子中,state将被一个单独的协程拥有。这能保证数据在并行读取时不会混乱。为了对state进行读取或者写入,其他的协程将发送一条数据到目前拥有数据的协程中,然后等待接收对应的回复。结构体readOp和writeOp封装了这些请求,并提供了相应协程的方法
 
 
和前面的例子一样,我们会计算操作执行的次数
 
其他协程将通过reads和writes通道来发布 读 和 写 请求。
 
这就是拥有state的那个协程,和前面例子中的map一样,不过这里的state是被这个状态协程私有的。这个协程不断地在reads和writes通道上进行选择,并在请求到达时做出相应。首先,执行请求的操作;然后,执行相应,在相应通道resp上发送一个值,表明请求成功(reads的值则为state对应的值)
 
 
 
启动100个协程通过reads通道向拥有state的协程发起读取请求。每个读取请求需要构造一个readOp,发送它到reads通道中,并通过给定的resp通道接收结果
 
 
 
 
 
用相同的方法启动10个写操作
 
 
 
 
 
 
 
 
 
让协程们跑1s
最后,获取并报告ops值
 
 
 
 
运行这个程序显示这个基于协程的状态管理的例子达到了每秒大约80000次操作
 
通过这个例子我们可以看到,基于协程的方法比基于互斥锁的方法要复杂的多,但是,在某些情况下它可能很有用,例如,当你涉及其他通道,或者管理多个同类互斥锁时,会很容易出错。您应该使用最自然的方法,尤其是在理解程序正确性方面。
上一篇:
39、互斥锁
下一篇:
41、排序

评论