- RWMutex内部维护两个计数器,一个是读计数器,一个是写计数器。
- 在读操作执行时,读计数器会加1,如果此时写计数器的值不为0,则说明有写操作正在进行,那么这个读操作就需要阻塞等待。
- 在写操作执行时,会先判断读计数器的值是否为0,如果不为0,则说明有读操作正在进行,那么这个写操作就需要阻塞等待。写操作执行时,会把写计数器加1,这样其他读写操作就无法继续执行了。
- 当读操作执行完毕时,读计数器会减1,如果此时读计数器的值为0,那么说明没有其他读操作在进行了,可以允许写操作了。
- 当写操作执行完毕时,写计数器会减1,如果此时写计数器的值为0,那么说明没有其他读写操作在进行了,此时其他读写操作就可以继续执行了。
当有大量读时,写操作不会饿死,这是因为读写锁支持优先处理写操作的。具体来说,当一个写操作请求锁时,如果此时已经有其他读或写操作持有锁,那么该写操作会被阻塞,等待其他操作释放锁。但是,一旦没有任何读或写操作持有锁,那么该写操作会立即获取到锁,并且优先执行,即使此时已经有很多读操作在等待。
也就是说读写锁并不是公平锁。因为并不保证等待时间最长的线程能够最先获取锁。
如果需要使用公平锁,可以考虑使用sync.Mutex,它保证等待时间最长的线程能够最先获取锁。但是需要注意的是,公平锁会导致额外的开销,因为它需要维护等待队列,进行线程切换等操作。