关于java:7Java锁之读写锁

概念

独占锁:该锁一次只能被一个线程锁持有(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();
  }
 ​
 }

运行结果显示:

解决办法

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

创立一个读写锁:

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

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

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

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

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

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

咱们就把MyCache类的put办法的最后面加上一个写锁,最初开释锁。get办法的最后面加一个读锁,最初开释锁。

最初咱们看看增加读写锁后的运行后果:

从运行后果咱们能够看出,写入操作是一个一个线程进行执行的,并且两头不会被打断,而读操作的时候,是同时5个线程进入,而后并发读取操作。

【腾讯云】轻量 2核2G4M,首年65元

阿里云限时活动-云数据库 RDS MySQL  1核2G配置 1.88/月 速抢

本文由乐趣区整理发布,转载请注明出处,谢谢。

您可能还喜欢...

发表回复

您的电子邮箱地址不会被公开。 必填项已用*标注

此站点使用Akismet来减少垃圾评论。了解我们如何处理您的评论数据