理解Go 语言中读写锁 RWMutex

avatar
作者
猴君
阅读量:2

读写锁是计算机程序并发控制的一种针结互斥锁优化的同步机制,也称 “共享-互斥锁” 、多读单写锁等,用于处理大量读、少量写的场景。读操作之间可并发进行,写操作之间是互斥的,读和写又是互斥的。这意味着多个 goroutine 可以同时读数据,但写数据时需要获得一个独占的锁。读写锁的常见用法是控制 goroutine 对内存中某个共享变量的访问,这个共享变量不能被原子性更新,并且对此数据结构的访问大部分时间是读,只有少量的写。

1. 读写锁的使用场景

互斥锁是 Go 语言中最常用的同步原语之一,而且使用起来非常简单,也经常用于控制对共享变量的访问,那为什么还要实现一个功能类似的读写锁呢?答案只有一个:为了性能。

我们使用一个互斥锁 Mutex 的例子做对比

func BenchmarkCounter_Mutex(b *testing.B) {     // 1.声明一个 int64 类型的变量,做计数     var counter int64     // 2. 声明一个互斥锁     var mu sync.Mutex      for i :=0; i < b.N; i++ {         // 3. 并发执行         b.RunParallel(func(pb *testing.PB) {             i := 0             // 4. 迭代测试             for pb.Next(){                 i++              // 5. 如果是10000的整数倍,则获取锁,计数值加 1             if i%10000 == 0 {                 mu.Lock()                 counter++                 mu.Unlock()             } else {                 // 6. 否则,只读取这个计数值                 mu.Lock()                 _= counter                 mu.Unlock()             }         }      })     } }

这个测试使用了一个互斥锁,在读写比大概是 10000:1 的情况下对计数值进行读/写,所以是一个读多写少的场景。

如果有多个 goroutine 读取 counter 的值,则必须互斥访问,同时只有一个 goroutine 可以读取 counter 的值,即使此时没有对 counter 的写入。

广告一刻

为您即时展示最新活动产品广告消息,让您随时掌握产品活动新动态!