class CachedData {
Object data;
volatile boolean cacheValid;
ReentrantReadWriteLock rwl = new ReentrantReadWriteLock();
void processCachedData() {
rwl.readLock().lock();//@1
if (!cacheValid) {
// Must release read lock before acquiring write lock
rwl.readLock().unlock();//@4
rwl.writeLock().lock();//@2
// Recheck state because another thread might have acquired
// write lock and changed state before we did.
if (!cacheValid) {//@3
data = ...
cacheValid = true;
}
// Downgrade by acquiring read lock before releasing write lock
rwl.readLock().lock();
rwl.writeLock().unlock(); // Unlock write, still hold read
}
use(data);
rwl.readLock().unlock();
}
}
rwl.writeLock().lock(); //在写锁状态中,可以获取读锁 rwl.readLock().lock(); rwl.writeLock().unlock();
rwl.readLock().lock(); //...... //必须释放掉读锁,才能够加写锁 rwl.readLock().unlock(); rwl.writeLock().lock();
package cn.com.scl.cache
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;
/**
* 缓存的实现,每个线程只能获得他自己的缓存,也应该是单例的
* 本类没有去实现单例,如果需要的话可以自行去实现
* @author scl
*
*/
public class CacheSystem {
private Map<String, Object> cache = new HashMap<String,Object>();
private ReadWriteLock rwl = new ReentrantReadWriteLock();
public Object getData(String key){
//先从缓存中去取数据,先加上读锁
rwl.readLock().lock();
Object obj = null;
try{
obj = cache.get(key);
if(obj == null){
//先解除读锁,在上写锁(必须先解除读锁才能成功上写锁)
rwl.readLock().unlock();
rwl.writeLock().lock();
//去数据库取数据,再判断一次是否为null,因为有可能多个线程获得写锁
try{
if(obj == null){
obj = new String("obj is get from db");
}
}finally{
//先上读锁,然后再解除写锁(这样可以成功完成,在解除写锁前获得读锁,写锁被降级--这翻译的api上的)
rwl.readLock().lock();
rwl.writeLock().unlock();//解除写锁,读锁仍然持有
}
}
}finally{
rwl.readLock().unlock();
}
return obj;
}
}
机械节能产品生产企业官网模板...
大气智能家居家具装修装饰类企业通用网站模板...
礼品公司网站模板
宽屏简约大气婚纱摄影影楼模板...
蓝白WAP手机综合医院类整站源码(独立后台)...苏ICP备2024110244号-2 苏公网安备32050702011978号 增值电信业务经营许可证编号:苏B2-20251499 | Copyright 2018 - 2025 源码网商城 (www.ymwmall.com) 版权所有