ReentrantReadWriteLock读写锁简单原理案例证明
ReentrantReadWriteLock存在原因?
我们知道List的实现类ArrayList,LinkedList都是非线程安全的,Vector类通过用synchronized修饰方法保证了List的多线程非安全问题,但是有个缺点:读写同步,效率低下。于是就出现了CopyOnWriteArrayList,它通过写时复制数组实现了读写分离,提高了多线程对List读的效率,适合多读少些的情况。同理:我们知道ReentrantLock,它是一把独占的锁,是用来控制线程同步的,如果我们用ReentrantLock来实现ArrayList安全,能否达到CopyOnWriteArrayList同样的效果呢?
import java.util.ArrayList; import java.util.List; import java.util.concurrent.locks.ReentrantReadWriteLock; /** * @author :jiaolian * @date :Created in 2021-01-26 15:49 * @description:ReentrantReadWriteLock多读少写的场景 * @modified By: * 公众号:叫练 */ public class MultReadTest { private static class MyList { private final ReentrantReadWriteLock REENTRANT_READ_WRITE_LOCK = new ReentrantReadWriteLock(); private final ReentrantReadWriteLock.WriteLock WRITE_LOCK = REENTRANT_READ_WRITE_LOCK.writeLock(); private final ReentrantReadWriteLock.ReadLock READ_LOCK = REENTRANT_READ_WRITE_LOCK.readLock(); private List<String> list = new ArrayList(); //读list public void readList() { try { READ_LOCK.lock(); Thread.sleep(1000); System.out.println(Thread.currentThread().getName()+":"+list.size()); } catch (InterruptedException e) { e.printStackTrace(); } finally { READ_LOCK.unlock(); } } //写list public void writeList() { try { WRITE_LOCK.lock(); Thread.sleep(1000); System.out.println(Thread.currentThread().getName()+":新增1个元素"); list.add("叫练【公众号】"); } catch (InterruptedException e) { e.printStackTrace(); } finally { WRITE_LOCK.unlock(); } } } public static void main(String[] args) { MyList myList = new MyList(); //读写锁适合多读少写情况 //新建10个读线程,1个写线程 new Thread(()->{myList.writeList();},"写线程").start(); for (int i=0; i<10; i++) { new Thread(()->{myList.readList();},"读线程"+(i+1)).start(); } } }
上面案例我们用ReentrantReadWriteLock实现了CopyOnWriteArrayList,主线程新建了1个写线程写list,10个读线程读list,程序一共花费2执行完毕,如果用Vector需要花费11秒。在多线程的情况下,通过读写锁操作List,提高了List的读效率,在List读的部分,线程是共享的,在对List写的过程中,在对写的线程是同步的,因此我们可以得出一个结论:读写锁是读读共享,读写同步!
独占获取锁简单流程
如上图,我们简单的梳理下独占获取锁流程。
- 独占锁获取(上述例子中的WRITE_LOCK写锁),首先判断是否有线程获取了锁,是否有线程获取了锁的判断通过读写锁中通过32位int类型state可以获取,其中低16位表示读锁,高16表示写锁。
- 有读锁:直接排队阻塞。
- 有写锁:还需要判断写锁线程是否是自己,如果是自己就是锁重入了,如果不是自己说明已经有其他的线程获取锁正在执行,那么当前线程需要排队阻塞。
- 无锁:直接获取锁,其他抢占的独占锁线程需要排队阻塞,当前线程执行完毕后释放锁通知下一个排队线程获取锁。
共享获取锁简单流程
如上图,我们简单的梳理下共享锁获取锁流程。
- 独占锁获取(上述例子中的READ_LOCK读锁),首先判断是否有线程获取了锁。
- 有读锁:当前线程发现此时读锁状态被占用,说明有线程获取了读锁。该线程通过cas自旋【死循环】获取到读锁为止。
- 有写锁:还需要判断持有写锁的线程是否是自己,如果是自己而且此时是获取的是读锁会获取锁成功,我们称为锁降级,如果不是自己说明此时有其他线程获取了写锁,那么当前线程需要排队阻塞。
- 无锁:直接获取锁。
写锁降级
我们说读写互斥,但同一个线程中,先写后读也是允许的,我们称之为锁降级。在面试中共享锁面试频率也比较高,方便理解我们举个简单的案例说明下。
import java.util.concurrent.locks.ReentrantReadWriteLock; /** * @author :jiaolian * @date :Created in 2021-01-28 15:44 * @description:ReentrantReadWriteLock读写锁降级测试 * @modified By: * 公众号:叫练 */ public class WriteLockLowerTest { private static final ReentrantReadWriteLock REENTRANT_READ_WRITE_LOCK = new ReentrantReadWriteLock(); private static final ReentrantReadWriteLock.WriteLock WRITE_LOCK = REENTRANT_READ_WRITE_LOCK.writeLock(); private static final ReentrantReadWriteLock.ReadLock READ_LOCK = REENTRANT_READ_WRITE_LOCK.readLock(); public static void main(String[] args) { try { WRITE_LOCK.lock(); System.out.println("获取写锁"); READ_LOCK.lock(); System.out.println("获取读锁"); } finally { READ_LOCK.unlock(); System.out.println("释放写锁"); WRITE_LOCK.unlock(); System.out.println("释放读锁"); } } }
如上述代码:程序可以运行完毕,说明锁可以降级。另外说一句,上面的程序先获取读锁再获取写锁,程序是会阻塞的,为什么呢?欢迎小伙伴在留言区写下评论!
总结
今天我们用通俗易懂的文字描述了ReentrantReadWriteLock读写锁。喜欢的请点赞加评论哦!点关注,不迷路,我是叫练【公众号】,边叫边练。期待我们下次再见!
- MVP 实现原理及简单案例登陆(二)
- 简单使用Spring的aop原理--案例
- C++基础7【难】 多态:实现原理 vptr指针 证明vptr存在 类的步长 纯虚函数:抽象类 案例 【面试题】
- spring之IOC工厂原理简单案例分析
- 互斥量原理及简单案例
- python自动化之爬虫原理及简单案例
- 简单工厂与工厂模式原理及案例分析
- [源码]Condition的原理,简单案例(ArrayBlockingQueue),复杂案例(LinkedBlockingQueue).
- 分布式计算,大型网站技术架构:核心原理与案例分析
- python在线编译器的简单原理及简单实现
- java agent技术原理及简单实现
- mDNS原理的简单理解——每个进入局域网的主机,如果开启了mDNS服务的话,都会向局域网内的所有主机组播一个消息,我是谁,和我的IP地址是多少。然后其他也有该服务的主机就会响应,也会告诉你,它是谁,它的IP地址是多少
- Java中的异常处理机制的简单原理和应用
- php图片加水印原理(超简单的实例代码)
- BP神经网络原理与应用-基于电影评分预测案例
- 服务器推送技术原理分析及dwr框架简单的使用
- 学习笔记6:《大型网站技术架构 核心原理与案例分析》之 万无一失:网站的高可用架构
- 简单的PHP新闻管理系统案例
- java通信一:Socket通信原理简单理解