之前的博客讲了使用互斥锁 sync.Mutex 来保证同一个时刻只有一个goroutine可以访问临界区(内部有共享变量)。当时更多时候,goroutine不是要修改共享变量,只是要读取就行,而互斥锁是完全互斥的。针对这种情况,golang中提供了读写锁 **sync.RWMutex ** ——它 不限制资源的并发读,但是读写、写写操作无法并行执行,这种锁叫作“多读单写”锁(multiple readers, single writer lock)。
sync.RWMutex.Locksync.RWMutex.Unlocksync.RWMutex.RLocksync.RWMutex.RUnlock
写锁
加写锁
sync.RWMutex.Lock
- 阻塞后续的写操作
- 阻塞后续的读操作
- 如果仍然有其他 Goroutine 持有互斥锁的读锁,该 Goroutine 进入休眠状态等待所有读锁所有者执行结束后,将当前协程唤醒
- 获取写锁时会先阻塞写锁的获取,后阻塞读锁的获取,这种策略能够保证读操作不会被连续的写操作『饿死』。
解写锁
sync.RWMutex.Unlock
sync/atomic.AddInt32readerCountsync.Mutex.Unlock
读锁
sync.RWMutex.RLocksync/atomic.AddInt32readerCount
- 如果其他 Goroutine 获得了写锁,当前 Goroutine 就会陷入休眠等待锁的释放;
sync.RWMutex.RUnlock
读锁和写锁的关系:
sync.RWMutex.Locksync.RWMutex.RUnlockreaderCountreaderCountrwmutexMaxReaderssync.RWMutex.Unlock