如何解决读写互斥锁如何工作？
| 假设我在没有多读取器/单编写器互斥锁的线程框架中进行编程。我可以通过以下方式实现其功能： 创建两个互斥锁：一个递归（锁定计数）的互斥锁（用于读取器）和一个二进制互斥量的写入器。 写： 获取二进制互斥锁 等到递归互斥锁的锁计数为零 实际写 释放二进制互斥锁 读： 获取二进制互斥锁的锁定（因此我知道编写器未处于活动状态） 递归互斥的增量计数 释放二进制互斥锁 实际阅读 递归互斥的递减计数 这不是功课。我没有接受并发编程方面的正式培训，并且正在尝试解决这些问题。如果有人可以指出缺陷，阐明不变量或提供更好的算法，我将非常高兴。一个很好的参考，无论是在线的还是枯树上的，也将不胜感激。解决方法
以下内容直接摘自《多处理器编程的艺术》，这是一本了解这些知识的好书。实际上提供了2种实现：简单版本和公平版本。我将继续复制公平版本。
此实现的要求之一是您具有条件变量原语。我会尝试找出一种删除它的方法，但这可能要花点时间。在那之前，这总比没有好。注意，也可以仅使用锁来实现该原语。
public class FifoReadWriteLock {
int readAcquires = 0,readReleases = 0;
boolean writer = false;
ReentrantLock lock;
Condition condition = lock.newCondition(); // This is the condition variable.
void readLock () {
lock.lock();
try {
while(writer)
condition.await();
readAcquires++;
}
finally {
lock.unlock();
}
}
void readUnlock () {
lock.lock();
try {
readReleases++;
if (readAcquires == readReleases)
condition.signalAll();
}
finally {
lock.unlock();
}
}
void writeLock () {
lock.lock();
try {
while (writer)
condition.await();
writer = true;
while (readAcquires != readReleases)
condition.await();
}
finally {
lock.unlock();
}
}
void writeUnlock() {
writer = false;
condition.signalAll();
}
}
readAcquires
readReleases
writer
readReleases
readAcquires
condition.await()
readReleases
readAcquires
readAcquires
readReleases
writer
wait until recursive mutex has lock count zero
ReadWriteLock
ReentrantReadWriteLock
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。