这是因为 , 在map内部,是hmap结构,主要包含元数据(例如,计数器)和引用数据桶的指针 。因此,online := u.online
不会复制实际数据,而是复制的指针 , 实际操作的还是同一片内存 。
解决这个问题也不难:
- 我们可以把锁的范围扩大,像下面这样:
func (u *User) AllOnline() int { u.mu.RLock() defer u.mu.RUnlock() online := u.online sum := 0 for _, o := range online {if o {sum++} } return sum}
- 另一种方法就是复制一个副本出来,像上面我们说的切片一样:
func (u *User) AllOnline() int { u.mu.RLock() online := make(map[string]bool, len(u.online)) for s, b := range u.online {online[s] = b } u.mu.RUnlock() sum := 0 for _, o := range online {if o {sum++} } return sum}
func (u *User) AddOnline(id string) { u.mu.Lock() u.online[id] = true u.mu.Unlock()}func (u *User) AllOnline() int { u.mu.RLock() online := make(map[string]bool, len(u.online)) for s, b := range u.online {online[s] = b } u.mu.RUnlock() sum := 0 for _, o := range online {if o {sum++} } return sum}
我现在我们稍微修改下上面的列子:package mainimport ( "strconv" "sync" "time")type User struct { musync.RWMutex online map[string]bool}func (u User) AddOnline(id string) { u.mu.Lock() u.online[id] = true u.mu.Unlock()}func (u User) AllOnline() int { u.mu.RLock() online := make(map[string]bool, len(u.online)) for s, b := range u.online {online[s] = b } u.mu.RUnlock() sum := 0 for _, o := range online {if o {sum++} } return sum}func main() { u := User{} u.online = make(map[string]bool) go func() {for i := 0; i < 10000; i++ {u.AddOnline("userid" + strconv.Itoa(i))} }() go func() {for i := 0; i < 10000; i++ {u.AllOnline()} }() time.Sleep(time.Second)}
现在我们直接使用User结构体定义这两个方法,但是当我们执行程序的时候,报了数据竞争的错误:gorun -race 10.go==================WARNING: DATA RACERead at 0x00c00011e060 by goroutine 7:main.User.AllOnline()
这个又是什么原因造成的呢?这是因为,当我门使用User作为参数时,直接复制了User的副本,因此sync.RWMutex也会被复制 。因为锁被复制了,所以对于同一个临界资源,处于不同锁的读写操作可以同时访问 。
【golang中的锁竞争问题】
推荐阅读
- Droplet——一款轻量的Golang应用层框架
- 荣耀magic3怎么设置指纹解锁_添加指纹解锁步骤
- 红米k40pro指纹解锁在哪里_红米k40pro指纹解锁的位置
- java中的垃圾回收算法与垃圾回收器
- JUC中的AQS底层详细超详解
- Briefings in Bioinformatics-2021 知识图谱-生物信息学-医学顶刊论文:生物信息学中的图表示学习:趋势、方法和应用
- 深入理解独占锁ReentrantLock类锁
- MySQL 全局锁、表级锁、行级锁,你搞清楚了吗?
- golang中的nil接收器
- 别惹农夫小炎子皮肤怎么解锁