• 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏吧

7.Java锁之读写锁

互联网 diligentman 3天前 4次浏览

概念

独占锁:该锁一次只能被一个线程锁持有(ReetrantLockSynchronized都是独占锁)

共享锁:该锁可以被多个线程持有

对ReentrantReadWriteLock而言,它的读锁是共享,写锁是独占。写的时候一个人写,但是可以多个人同时读。

为什么会有写锁和读锁

原来我们使用ReentrantLock创建锁的时候,是独占锁,也就是说一次只能一个线程访问。但是有一个读写分离场景,读的时候想同时进行,因为读锁并不会造成数据不一致的问题,因此可以多个人共享读。

多个线程同时去读一个资源类没有任何问题,如果一个线程想去写共享内存,就不应该有其他线程对该资源进行读或写。

代码实现

  • 实现一个读写缓存的操作,假设开始没有加锁的时候,会出现什么情况

先模拟出HashMap的putget方法:

 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();
  }
 ​
 }

运行结果显示:

7.Java锁之读写锁

解决方法

上面的代码是没有加锁的,这样就会造成线程在进行写入操作的时候,被其他线程频繁打断,从而不具备原子性,这时候,我们就需要用到读写锁来解决了。

创建一个读写锁:

 private ReentrantReadWriteLock rwLock = new ReentrantReadWriteLock();
 ​
 //它是一个读写融为一体的锁,在使用的时候,需要转换

当我们在进行写操作的时候,就需要转换成写锁:

 // 创建一个写锁
 rwLock.writeLock().lock();
 ​
 // 写锁 释放
 rwLock.writeLock().unlock();

当们在进行读操作的时候,在转换成读锁

 // 创建一个读锁
 rwLock.readLock().lock();
 ​
 // 读锁 释放
 rwLock.readLock().unlock();

这里的读锁和写锁的区别在于,写锁一次只能一个线程进入,执行写操作,而读锁是多个线程能够同时进入,进行读取的操作。

我们就把MyCache类的put方法的最前面加上一个写锁,最后释放锁。get方法的最前面加一个读锁,最后释放锁。

最后我们看看添加读写锁后的运行结果:

7.Java锁之读写锁

从运行结果我们可以看出,写入操作是一个一个线程进行执行的,并且中间不会被打断,而读操作的时候,是同时5个线程进入,然后并发读取操作。


程序员灯塔
转载请注明原文链接:7.Java锁之读写锁
喜欢 (0)