一、读写锁是什么? 读写锁其实还是一种锁,是给一段临界区代码加锁,但是此加锁是在进行写操作的时候才会互斥,而在进行读的时候是可以共享的进行访问临界区的 ps:读写锁本质上是一种自旋锁 二、为什么需要读写锁? 读写之间是互斥的—–>读的时候写阻塞,写的时候读阻塞,而且读和写在竞争锁的时候,写会优先得到锁 四、自旋锁&挂起等待是锁? :效率不高,很可能会使临界区的代码不被任何线程执行,因为可能会是线程被 CPU调度走了但是却没有被调度回来 五、读写锁是怎么实现? ,写会优先的得到锁 互斥---->读的时候写阻塞,写的时候读阻塞 4.相关函数 (1)pthread_rwlock_init()—->初始化函数 功能:初始化读写锁 头文件:#include<pthread.h
一,使用互斥锁 1,初始化互斥量 不能拷贝互斥量变量,但可以拷贝指向互斥量的指针,这样就可以使多个函数或线程共享互斥量来实现同步。上面动态申请的互斥量需要动态的撤销。 二,使用读写锁 通过读写锁,可以对受保护的共享资源进行并发读取和独占写入。读写锁是可以在读取或写入模式下锁定的单一实体。要修改资源,线程必须首先获取互斥写锁。 必须释放所有读锁之后,才允许使用互斥写锁。 初始化和销毁: 同互斥量一样, 在释放读写锁占用的内存之前, 需要先通过pthread_rwlock_destroy对读写锁进行清理工作, 释放由init分配的资源. 2.加锁和解锁 三,条件变量
排它锁: 之前的Synchronized和ReentrantLock都是排他锁,默认只有一个线程可以占用 读写锁: 读写锁,同一时刻允许多个读线程同时访问,但是写线程访问的时候,所有的读和写都被阻塞 ,最适宜与读多写少的情况 通过解释,我们可以知道读写锁,最常用的就是读多写少的场景,读写锁相比于普通的排它锁,提高了很高的读取性能 接口: ReadWriteLock ? 但是他的内部的读锁和写锁,还是实现了Lock接口 演示读写锁,在读多写少的情况下,读写锁,相对于Sync排它锁的性能提升 定义商品实体类 package org.dance.day4.rw; /** ** * 创建读写锁,默认使用非公平锁 */ private final ReadWriteLock lock = new ReentrantReadWriteLock(); ,在读写分离时使用,相对于Synchronized排他锁来说,性能提升了10倍不止,所以在读多写少的时候,推荐使用读写锁 作者:彼岸舞 时间:2020\11\03 内容关于:并发编程 本文来源于网络,只做技术分享
,包括重入次数,获取到读锁一次加 1,释放掉读锁一次减 1。 state 的低 16 位代表写锁的获取次数,因为写锁是独占锁,同时只能被一个线程获得,所以它代表重入次数 每个线程都需要维护自己的HoldCounter,记录该线程获取的读锁次数,这样才能知道到底是不是读锁重入 ,避免写锁饥饿(这里是给了写锁更高的优先级,所以如果碰上获取写锁的线程马上就要获取到锁了,获取读锁的线程不应该和它抢。 return free; } 独占锁的释放很简单,直接state减1就好 StampedLock ReadWriteLock 可以解决多线程读写的问题, 但是读的时候, 写线程需要等待读线程释放了才能获取写锁 jdk8 引入了新的读写锁:StampedLock, 进一步提升了并发执行效率。 StampedLock和ReadWriteLock相比,改进之处在于:读的过程中也允许获取写锁后写入。
读锁:共享锁 readLock **写锁:**独占锁 writeLock 读写锁 : 一个资源可以被多个读的线程进行访问 ,或者可以被一个写的线程访问, 但是不能同时存在读和写进程 ,读写互斥,读读共享 unlock(); class MyCacheLock { private volatile Map<String, Object> map = new HashMap<>(); //读写锁 : 一、无锁 无锁状态多线程抢占资源 会出现问题 二、加锁 synchronized和reentrantLock 都是独占锁 每次只能一个线程来操作 读读 一个线程 只能一个人读 读写 一个线程 写写 一个线程 三、读写锁 ReentrantReadWriteLock 读读可以共享,提升性能 同时多人读 写写 一个线程 缺点: 1.造成锁的饥饿,可能一直读没有写的操作 2.写的时候,自己线程可以读,读的时候 示例: public class Downgrade { public static void main(String[] args) { //可重入读写锁对象
关于读写锁的定义可以到网上查询,这里不再啰嗦了。 1. 场景: 多个线程同时读写,读线程的数量远远大于写线程,该怎么办? 如果我们只是简单的使用lock方式去加锁,则会影响性能。 如果采用读写锁,那么多个线程可以同时读取该对象,只有等到对象被写入锁占用的时候,才会阻塞。 也就是说某个线程进入了写入模式,那么其他线程无论是要写入还是读取,都是会被阻塞的。
读写锁内部维护了两个锁,一个用于读操作,一个用于写操作。所有 ReadWriteLock实现都必须保证 writeLock操作的内存同步效果也要保持与相关 readLock的联系。 定义一个Map来模拟缓存 */ private Map<String, Object> cache = new HashMap<String, Object>(); /* 创建一个读写锁 } public void setCache(Map<String, Object> cache) { this.cache = cache; } } 示例二:高并发读写共享数据 可以选择读写锁,支持并发读,独占写,提高并发。 singleFactory.INSTANCE; } /* 共享数据,只能一个线程写数据,可以多个线程读数据 */ private Object data = null; /* 创建一个读写锁
读写锁 1、读写锁介绍 2、读写锁入门案例 3、锁降级测试 4、小结 1、读写锁介绍 现实中有这样一种场景:对共享资源有读和写的操作,且写操作没有读操作那么频繁。 针对这种场景,JAVA 的并发包提供了读写锁 ReentrantReadWriteLock,它表示两个锁,一个是读操作相关的锁,称为共享锁;一个是写相关的锁,称为排他锁。 线程进入读锁的条件: 没有其他线程的写锁 没有写请求,或者有写请求,但调用线程和持有锁的线程是同一个(可重入锁) 线程进入写锁的前提条件: 没有其他线程的读锁 没有其他线程的写锁 读写锁有以下三个重要的特性 2、读写锁入门案例 场景:使用读写锁对一个hashmap进行读和写操作 import java.util.HashMap; import java.util.Map; import java.util.concurrent.TimeUnit //演示读写锁降级 public class Demo1 { public static void main(String[] args) { //可重入读写锁对象
续接上一篇“线程同步”:https://blog.csdn.net/zy010101/article/details/105967289 本文讲述读写锁。 读写锁和互斥量不太一样,它允许锁可以是读加锁,写加锁以及未加锁三种状态。每次只能由一个线程处于写加锁状态,但是可以有多个线程处于读加锁状态。 读写锁是一把锁,不是两把锁。它就像是多路开关一样。 读写锁很明显带来了比互斥量更高的并发性。并且读写锁非常适合读取比写入操作更多的情况。有的教材会把读写锁也称为“共享互斥锁”。 当读写锁以写模式锁住,称之为“共享模式锁住”;而当读写锁以读模式锁住,称之为“互斥模式锁住”。 下面是供我们在POSIX下进行读写锁初始化和反向初始化的函数。 ? 下面是与写加锁的函数。 ? 由于读写锁是一把锁,因此在解锁的时候无论你是读加锁,还是写加锁,都是使用下面的解锁函数。 ?
一、读写锁 1、初识读写锁 a)Java中的锁——Lock和synchronized中介绍的ReentrantLock和synchronized基本上都是排它锁,意味着这些锁在同一时刻只允许一个线程进行访问 读写锁维护一对锁(读锁和写锁),通过锁的分离,使得并发性提高。 如果改用读写锁实现,只需要在读操作的时候获取读锁,写操作的时候获取写锁。当写锁被获取到的时候,后续操作(读写)都会被阻塞,只有在写锁释放之后才会执行后续操作。 );11 } b)关于读写读写状态的设计 ①作为已经实现的同步组件,读写锁同样是需要实现同步器来实现同步功能,同步器的同步状态就是读写锁的读写状态,只是读写锁的同步器需要在同步状态上维护多个读线程和写线程的状态 对比下图,低位值表示当前获取写锁的线程重入两次,高位的值表示当前获取读锁的线程重入一次。读写锁的获取伴随着读写状态值的更新。
,包括重入次数,获取到读锁一次加 1,释放掉读锁一次减 1。 state 的低 16 位代表写锁的获取次数,因为写锁是独占锁,同时只能被一个线程获得,所以它代表重入次数 每个线程都需要维护自己的HoldCounter,记录该线程获取的读锁次数,这样才能知道到底是不是读锁重入 ,避免写锁饥饿(这里是给了写锁更高的优先级,所以如果碰上获取写锁的线程马上就要获取到锁了,获取读锁的线程不应该和它抢。 return free; } 独占锁的释放很简单,直接state减1就好 StampedLock ReadWriteLock 可以解决多线程读写的问题, 但是读的时候, 写线程需要等待读线程释放了才能获取写锁 jdk8 引入了新的读写锁:StampedLock, 进一步提升了并发执行效率。 StampedLock和ReadWriteLock相比,改进之处在于:读的过程中也允许获取写锁后写入。
所以就针对某些操作read thread占绝大多数的情况下,提出了读写锁的概念。 lock; } arch_rwlock_t; 可以看到读写锁与spin_lock的定义最终相同,只是名字不同罢了。 同时使能cpu中断的下半部 读写锁的实现 写入者加锁操作: /* * Write lock implementation 从概率上将,当一个进程试图去写时,成功获得锁的几率要远小于读进程概率。所以在一个读写相互依赖的系统中,这种设计会导致读取者饥饿,也就是没有数据可读。 所以读写锁使用的系统就是读操作占用绝大多数,这样读写操作就比以前的spin lock大大提升效率和性能。
读写锁 与互斥量类似,但读写锁允许更高的并行性。其特性为:写独占,读共享。 读写锁状态: 一把读写锁具备三种状态: 1. 读模式下加锁状态 (读锁) 2. 写模式下加锁状态 (写锁) 3. 不加锁状态 读写锁特性: 1. 读写锁是“写模式加锁”时, 解锁前,所有对该锁加锁的线程都会被阻塞。 2. 那么读写锁会阻塞随后的读模式锁请求。优先满足写模式锁。读锁、写锁并行阻塞,写锁优先级高 读写锁也叫共享-独占锁。当读写锁以读模式锁住时,它是以共享模式锁住的;当它以写模式锁住时,它是以独占模式锁住的。 读写锁非常适合于对数据结构读的次数远大于写的情况。 函数 以读方式请求读写锁。
这个问题模型是从对文件的读写操作中引申出来的。把对资源的访问细分为读和写两种操作模式,这样可以大大增加并发效率。读写锁比互斥锁适用性更高,并行性也更高。 需要注意的是,这里只是说并行效率比互斥高,并不是速度一定比互斥锁快,读写锁更复杂,系统开销更大。 二 读写锁特点 1 如果一个线程用读锁锁定了临界区,那么其他线程也可以用读锁来进入临界区,这样可以有多个线程并行操作。这个时候如果再用写锁加锁就会发生阻塞。 三 读写锁使用的函数 操作 相关函数说明 初始化读写锁 pthread_rwlock_init 语法 读取读写锁中的锁 pthread_rwlock_rdlock 语法 读取非阻塞读写锁中的锁 pthread_rwlock_tryrdlock 语法 写入读写锁中的锁 pthread_rwlock_wrlock 语法 写入非阻塞读写锁中的锁 pthread_rwlock_trywrlock 语法 解除锁定读写锁 pthread_rwlock_unlock
读写锁的使用 读写锁在 Java 中是 ReentrantReadWriteLock,使用方式是: import java.util.concurrent.locks.ReentrantReadWriteLock 使用ReentrantReadWriteLock读写锁的方式,会调用readLock()和writeLock()两个方法,看下他们的源码: public ReentrantReadWriteLock.WriteLock 再往下的内容估计看过前面几篇文章的都很熟悉了,独占锁通过state变量的0和1两个状态来控制是否有线程占有锁,共享锁通过state变量0或者非0来控制多个线程访问。 ReentrantReadWriteLock也会发生写请求饥饿的情况,因为写请求一样会排队, 不管是公平锁还是非公平锁,在有读锁的情况下,都不能保证写锁一定能获取到,这样只要读锁一直占用,就会发生写饥饿的情况 当然是有的,那就是JDK8中新增的改进读写锁---StampedLock.
什么是RWMutex锁 RWMutex锁也称为读写锁,在互斥锁Mutex实现介绍了Mutex(互斥)锁。相比Mutex锁,RWMutex将锁操作分为更细的读锁和写锁。 这样读写操作类型组合起来有读读操作、写写操作和读写操作三种。读读操作是可以并发的,因为没有对变量进行修改操作。 但读写操作和写写操作因都有写操作需要串行执行,这时RWMutex退化成了Mutex锁的功能。在有大量的并发读和少量并发写的场景中,可以考虑使用读写锁RWMutex替换Mutex换取更高的性能。 所以无论是写锁优先还是读锁优先,都有可能导致读写操作的饥饿。为了保障公平性,Go中RWMutex锁实现是按操作执行的时候时间排队,读写操作没有优先级之分,按先来后到的顺序执行。 在延时比较小的时候,读写锁的性能提升相比延时大的情况要弱一些。
读写锁(ReadWriteLock): java.util.concurrent.locks.ReadWriteLock接口定义了读取和写入锁的规则。 虽然它本身不是悲观锁,但其中的写锁部分是一种悲观锁策略。写锁会阻止其他线程进行读和写操作,直到持有锁的线程释放它。 分布式锁: 在分布式系统中,悲观锁的概念可以扩展到跨多个进程或机器。 读写锁 Java中的读写锁(ReadWriteLock)是一种允许多个读线程和单个写线程访问共享资源的同步机制。 读写锁的特性: 读共享:在没有线程持有写锁时,多个线程可以同时持有读锁来读取共享资源。这可以提高并发性能,因为读操作通常不会修改数据,所以允许多个读线程并发访问是安全的。 Java中ReadWriteLock接口的主要实现类是ReentrantReadWriteLock,它提供了可重入的读写锁实现。
Java读写锁,也就是ReentrantReadWriteLock,其包含了读锁和写锁,其中读锁是可以多线程共享的,即共享锁,而写锁是排他锁,在更改时候不允许其他线程操作。 读写锁底层是同一把锁(基于同一个AQS),所以会有同一时刻不允许读写锁共存的限制。 读写锁 示例代码如下: public static void main(String[] args) { ReentrantReadWriteLock lock = new ReentrantReadWriteLock 公平模式和非公平模式 对于读写锁来说,如果已加读锁,写锁会阻塞;如果已加写锁,读锁会阻塞。 非公平锁模式,可提高加锁效率(这也是一般的锁模式是非公平的原因),但是可能会造成阻塞线程一直获取不到锁。 因此从原理上来讲,读写锁的非公平模式下的读锁插队竞争锁会导致等待写锁的线程一致阻塞(线程饥饿)。 那读写锁是如何处理的呢?
在上一篇文章,我们已经实现了分布式锁。今天更进一步,在分布式锁的基础之上,实现读写锁。 ://zh.wikipedia.org/wiki/读写锁 读写锁是计算机程序的并发控制的一种同步机制,用于解决读写问题,读操作可并发重入,写操作是互斥的。 读写锁有多种读写权限的优先级策略,可以设计为读优先、写优先或不指定优先级。 读优先:允许最大并发的读操作,但可能会饿死写操作;因为写操作必须在没有任何读操作的时候才能够执行。 这样,就可以使用节点名来区分读锁和写锁。 2.2 类设计 介绍分布式锁的时候,已经创建了阻塞锁 ChildrenBlockingLock,读写锁正好可以基于这个类做重载。 ? 所以只需要判断有没有写锁即可。 3 关键代码 3.1 ChildrenNodeLock.java 这个类,主要是增加了一个获取排序后子节点列表的方法,这样方便实现读写锁的代码。
一 先搞清楚读写锁要做什么。 基本就是 读读不互斥,读写互斥,写写互斥。可重入。 关于redis读写锁,我写了一次之后,总觉得很怪,然后就上网看到大神的redisson了,果断借鉴一番。 2.读写锁获取锁的时候,是两个redis操作,原子性不行,所以要用redis的eval命令或者直接使用lua脚本。 ps. spring自带的redisTemplate则没有提供eval的接口,只提供使用lua脚本,相应的读写锁代码要自己写。 但是这里是读写锁的存活时间而不是读锁的时间。 并且publish到相应的频道,更新状态。 ,看来就是数据使用次数越多读写锁存活的时间越长,而具体的读锁写锁的存活时间则是hashmap里面的一个属性。