大神们,最近在学习并发的ReadWriteLock锁不明白一个地方。。。以下的代码是网上得到的,是描述ReadWriteLock很经典的一个例子,测试函数是我自己写的。
我想问的是,为什么还是没锁住执行数据库那边,他还是执行了3次。。。按道理来说不应该只执行一次才能达到这个实验的目的吗?究竟是哪里的问题
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;
public class CacheDemo {
private Map map = new HashMap();// 缓存器
private ReadWriteLock rwl = new ReentrantReadWriteLock();
public static void main(String[] args) {
CacheDemo c = new CacheDemo();
for (int i = 0; i < 3; i++) {
new Thread() {
public void run() {
System.out.println(c.get("3"));
}
}.start();
}
}
public Object get(String id) {
Object value = null;
try {
rwl.readLock().lock();// 首先开启读锁,从缓存中去取
value = map.get(id);
if (value == null) { // 如果缓存中没有释放读锁,上写锁
try {
rwl.readLock().unlock();
rwl.writeLock().lock();
if (value == null) {
System.out.println("执行了一次数据库");
value = "queryDB";
// map.put(id, value);
}
} finally {
rwl.writeLock().unlock(); // 释放写锁
}
rwl.readLock().lock(); // 然后再上读锁
}
} finally {
rwl.readLock().unlock(); // 最后释放读锁
}
return value;
}
}