兄弟连Go语言培训清华尹成带你实战GO案例（1） Go 状态协程

　　兄弟连GO语言培训课程体系设计架构包括了区块链的基础语言Go语言、区块链后端技术体系、区块链公链、区块链分布式应用开发等内容讲解，以及到最后的面试指导和项目实战。课程由清华微软谷歌名师团队精心打造，历时半年时间共同研发而出。 　　Go状态协程 　　在上面的例子中，我们演示了如何通过使用mutex来在多个协程之间共享状态。另外一种方法是使用协程 　　内置的同步机制来实现。这种基于通道的方法和Go的通过消息共享内存，保证每份数据为单独的协程所有 　　的理念是一致的。 　　packagemain 　　import( 　　"fmt" 　　"math/rand" 　　"sync/atomic" 　　"time" 　　) 　　//在这个例子中，将有一个单独的协程拥有这个状态。这样可以 　　//保证这个数据不会被并行访问所破坏。为了读写这个状态，其 　　//他的协程将向这个协程发送信息并且相应地接受返回信息。 　　//这些`readOp`和`writeOp`结构体封装了这些请求和回复 　　typereadOpstruct{ 　　keyint 　　respchanint 　　} 　　typewriteOpstruct{ 　　keyint 　　valint 　　respchanbool 　　} 　　funcmain(){ 　　//我们将计算我们执行了多少次操作 　　varopsint64=0 　　//reads和writes通道将被其他协程用来从中读取或写入数据 　　reads:=make(chan*readOp) 　　writes:=make(chan*writeOp) 　　//这个是拥有`state`的协程，`state`是一个协程的私有map 　　//变量。这个协程不断地`select`通道`reads`和`writes`， 　　//当有请求来临的时候进行回复。一旦有请求，首先执行所 　　//请求的操作，然后给`resp`通道发送一个表示请求成功的值。 　　gofunc(){ 　　gofunc(){ 　　varstate=make(map[int]int) 　　for{ 　　select{ 　　caseread:=<-reads: 　　read.resp<-state[read.key] 　　casewrite:=<-writes: 　　state[write.key]=write.val 　　write.resp<-true 　　} 　　} 　　}() 　　//这里启动了100个协程来向拥有状态的协程请求读数据。 　　//每次读操作都需要创建一个`readOp`，然后发送到`reads` 　　//通道，然后等待接收请求回复 　　forr:=0;r<100;r++{ 　　gofunc(){ 　　for{ 　　read:=&readOp{ 　　key:rand.Intn(5), 　　resp:make(chanint)} 　　reads<-read 　　<-read.resp 　　atomic.AddInt64(&ops,1) 　　} 　　}() 　　} 　　//我们开启10个写协程 　　forw:=0;w<10;w++{ 　　gofunc(){ 　　for{ 　　write:=&writeOp{ 　　key:rand.Intn(5), 　　val:rand.Intn(100), 　　resp:make(chanbool)} 　　writes<-write 　　<-write.resp 　　atomic.AddInt64(&ops,1) 　　} 　　}() 　　} 　　//让协程运行1秒钟 　　time.Sleep(time.Second) 　　//最后输出操作数量ops的值 　　opsFinal:=atomic.LoadInt64(&ops) 　　fmt.Println("ops:",opsFinal) 　　} 　　运行结果 　　ops:880578 　　运行这个程序，我们会看到基于协程的状态管理每秒可以处理800,000个操作。对于这个例子来讲，基于 　　协程的方法比基于mutex的方法更加复杂一点。当然在某些情况下还是很有用的。例如你有很多复杂的协 　　程，而且管理多个mutex可能导致错误。 　　当然你可以选择使用任意一种方法，只要你保证这种方法让你觉得很舒服而且也能保证程序的正确性。