举例说明Java多线程编程中读写锁的使用
|
以下示例为 java api并发库中 ReentrantReadWriteLock自带的实例，下面进行解读
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();
}
}
当有n多线程 使用同一CachedData 实例对象 调用processCachedData方法时，就会产生线程的并发问题. 当写完后，在该线程上加上读锁操作，以防止解写锁后，别的线程对数据再次进行写时出错.在第一个运行到@2的线程之后的很多线程， 可能已经运行到了@4,当对数据修改好之后，解除掉写锁，别的线程就会执行到@2，这时第一个线程已经经数据修改好了，所以有了@3的判断。 在编写多线程程序的时候,要置于并发线程的环境下考虑，巧妙的运用ReentrantReadWriteLock，在运用时，注意锁的降级，写入锁可以获得读锁，读锁不可以获得写入锁，所以在上写入锁时，必须先将读锁进行解除，然后上读锁。 使用时注意的几个方面： 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;
}
}
（编辑：李大同） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |