概念
独占锁:该锁一次只能被一个线程锁持有(ReetrantLock
和Synchronized
都是独占锁)
共享锁:该锁能够被多个线程持有
对ReentrantReadWriteLock而言,它的读锁是共享,写锁是独占。写的时候一个人写,然而能够多集体同时读。
为什么会有写锁和读锁
原来咱们应用ReentrantLock创立锁的时候,是独占锁,也就是说一次只能一个线程拜访。然而有一个读写拆散场景,读的时候想同时进行,因为读锁并不会造成数据不统一的问题,因而能够多集体共享读。
多个线程同时去读一个资源类没有任何问题,如果一个线程想去写共享内存,就不应该有其余线程对该资源进行读或写。
代码实现
- 实现一个读写缓存的操作,假如开始没有加锁的时候,会呈现什么状况
先模拟出HashMap的put
和get
办法:
public class MyCache {
private volatile Map<String,Object> map = new HashMap<>();
//写入的办法
public void put(String key,Object value) throws InterruptedException {
System.out.println(“线程”+ Thread.currentThread().getName() +”正在写入:” + key);
TimeUnit.MILLISECONDS.sleep(300); //模仿网络拥挤,提早0.3s
map.put(key,value); //写入元素
System.out.println(“线程”+ Thread.currentThread().getName() +”写入胜利”);
}
//读取的办法
public void get(String key) throws InterruptedException {
System.out.println(“线程”+ Thread.currentThread().getName() +”正在读取:”);
TimeUnit.MILLISECONDS.sleep(300); //模仿网络拥挤,提早0.3s
Object value = map.get(key); //读取元素
System.out.println(“线程”+ Thread.currentThread().getName() +”读取实现:” + value );
}
}
测试:
public static void main(String[] args) {
MyCache myCache = new MyCache();
//创立5个线程写入缓存
for (int i = 0; i < 5; i++) {
final int tempInt = i; //lambda表达式外部变量必须是final
new Thread(() -> {
myCache.put(tempInt + “”, tempInt + “”);
}, “线程” + i).start();
}
//创立5个线程读取缓存
for (int i = 0; i < 5; i++) {
final int tempInt = i; //lambda表达式外部变量必须是final
new Thread(() -> {
myCache.get(tempInt + “”);
}, “线程” + i).start();
}
}
运行结果显示:
解决办法
下面的代码是没有加锁的,这样就会造成线程在进行写入操作的时候,被其余线程频繁打断,从而不具备原子性,这时候,咱们就须要用到读写锁来解决了。
创立一个读写锁:
private ReentrantReadWriteLock rwLock = new ReentrantReadWriteLock();
//它是一个读写融为一体的锁,在应用的时候,须要转换
当咱们在进行写操作的时候,就须要转换成写锁:
// 创立一个写锁
rwLock.writeLock().lock();
// 写锁 开释
rwLock.writeLock().unlock();
当们在进行读操作的时候,在转换成读锁
// 创立一个读锁
rwLock.readLock().lock();
// 读锁 开释
rwLock.readLock().unlock();
这里的读锁和写锁的区别在于,写锁一次只能一个线程进入,执行写操作,而读锁是多个线程可能同时进入,进行读取的操作。
咱们就把MyCache类的put办法的最后面加上一个写锁,最初开释锁。get办法的最后面加一个读锁,最初开释锁。
最初咱们看看增加读写锁后的运行后果:
从运行后果咱们能够看出,写入操作是一个一个线程进行执行的,并且两头不会被打断,而读操作的时候,是同时5个线程进入,而后并发读取操作。