golang多个消费者访问共享数据
package main
import (
"fmt"
"sync"
)
var sum int
var rmutex sync.RWMutex
//生产者
func sheng(out chan <-int ) {
for i:=0;i<=100;i++{
out<-i
}
close(out)
}
//消费者
func xiao(in <-chan int) {
rmutex.RLock()
for num:= range in{
sum+=num
}
fmt.Println(sum)
rmutex.RUnlock()
}
func main() {
c:=make(chan int)
//创建一个生产者
go sheng(c)
//创建一个消费者
go xiao(c)
xiao(c)
for {
;
}
}