利用ReentrantReadWriteLock实现缓存系统

 

首先解释下缓存系统：

           在程序运行过程中，有些数据我们不会经常修改，例如数据库中性别字段，但是我们却经常使用，如果每次都从数据库中获取，那么将会降低程序性能。那么我们可以在内存中分配一个区域专门存放我们第一次从数据库中拿出的数据。思路如下：我们使用Map来充当我们的缓存区域，当使用性别值时，可以先看看map中是否有值，如果有那么拿出来，如果没有那么查询数据库，并为map赋值。

 

           思路如上，但是我们要考虑多线程的问题，如果多个程序同时使用该缓存系统，有的读，有的写，那么很有可能在某一时刻，一个线程为map赋值了，但是另一个线程或多个线程会重复为map赋值。这就是多线程的并发问题，如何解决，我们采用Java5的读写锁来实现。ReentrantReadWriteLock（详细解释参见Java5 API)。读锁和写锁同步，读的时候不允许写，写的时候不允许读，可以同时读。

 

 

import java.util.HashMap;  
import java.util.Map;  
import java.util.concurrent.locks.ReentrantReadWriteLock;  
  
public class CacheDemo {  
  
    private static Map<String, Object> cacheData = new HashMap<String, Object>();//构造缓存对象  
    private ReentrantReadWriteLock rwl = new ReentrantReadWriteLock();//构造读写锁  

    public static void main(String[] args) {  
                    
    }  
  
      
    public Object getData(String key){  
        Object value = null;  
        try{  
            rwl.readLock().lock();//当线程开始读时，首先开始加上读锁  
            value = cacheData.get(key);//获取值  
            if(value == null){//判断是否存在值  
                try{  
                    rwl.readLock().unlock();//在开始写之前，首先要释放写锁，否则写锁无法拿到  
                    rwl.writeLock().lock();//获取写锁开始写数据  
		    /* 再次判断该值是否为空，因为如果两个写线程如果都阻塞在这里，当一个线程  
                    *  被唤醒后value的值不为null，当另外一个线程也被唤醒如果不判断就会执行两次写  
		    */
                    if(value == null){
                        value = "queryDB";  
                        cacheData.put(key, value);  
                    }  
                    rwl.readLock().lock();//读完之后重入降级为读锁  
                }finally{  
                    rwl.writeLock().unlock();//最后释放写锁  
                }  
            }  
        }finally{  
            rwl.readLock().unlock();//释放读锁  
        }  
        return value;  
    }  

 

http://blog.csdn.net/lb85858585/article/details/7256278