被加锁的对象是共享数据,不是线程
1,put,get方法入口处设置断点,debug验证:可以同时有2个读线程,但最多只能有一个写线程
2,用ReentrantReadWriteLock实现线程安全的cache
/** * @author timeriver.wang * @date 2014-03-10 1:37:11 PM */ public class ReadWriteLockTest { public static void main(String[] args) { final Queue3 q3 = new Queue3(); for(int i=0;i<2;i++){ new Thread("r-"+i){ public void run(){ while(true){ q3.get(); } } }.start(); new Thread("w-"+i){ public void run(){ while(true){ q3.put(new Random().nextInt(10000)); } } }.start(); } } } class Queue3{ private Object data = null;//共享数据,只能有一个线程能写该数据,但可以有多个线程同时读该数据。 ReadWriteLock rwl = new ReentrantReadWriteLock(); public void get(){ rwl.readLock().lock(); try { System.out.println(Thread.currentThread().getName() + " be ready to read data!"); //验证,多个读线程可以并发读数据。******************************重要!!!!!! Thread.sleep((long)(Math.random()*1000)); System.out.println(Thread.currentThread().getName() + " have read data :" + data); } catch (InterruptedException e) { e.printStackTrace(); }finally{ rwl.readLock().unlock(); } } public void put(Object data){ rwl.writeLock().lock(); try { System.out.println(Thread.currentThread().getName() + " be ready to write data!"); Thread.sleep((long)(Math.random()*1000)); this.data = data; System.out.println(Thread.currentThread().getName() + " have write data: " + data); } catch (InterruptedException e) { e.printStackTrace(); }finally{ rwl.writeLock().unlock(); } } }
2 线程安全的cache
/** * @author timeriver.wang * @date Mar 10, 2014 3:26:15 PM */ public class MyThreadSafeCache { private Map<String,Object> cache = new HashMap<String,Object>(); private ReadWriteLock rwl = new ReentrantReadWriteLock(); public static void main(String[] args) { System.out.println(new MyThreadSafeCache().getData("java")); } public Object getData(String key){ rwl.readLock().lock(); Object value = null; try { value = cache.get(key); if(value == null){ rwl.readLock().unlock(); rwl.writeLock().lock(); value = "aaa"; cache.put("java", value); //本方法的最终目的是read,现在还没有get到数据,还需要占用readLock //把读锁提前,可以保证还是当前线程在执行(占用cpu) rwl.readLock().lock(); rwl.writeLock().unlock(); } return value; }finally{ rwl.readLock().unlock(); } } }
相关推荐
在学习Java过程中,自己收集了很多的Java的学习资料,分享给大家,有需要的欢迎下载,希望对大家有用,一起学习,一起进步。
在Java多线程并发编程中,ReentrantReadWriteLock(可重入读写锁)是一个重要的同步工具,它属于Java并发包(java.util.concurrent.locks)中的一个类。这个锁提供了比标准的synchronized关键字更细粒度的控制,允许...
读写锁ReentrantReadWriteLock&StampLock详解_e读写锁ReentrantReadWriteLock&StampLock详解_e读写锁ReentrantReadWriteLock&StampLock详解_e读写锁ReentrantReadWriteLock&StampLock详解_e读写锁...
ReadWriteLock 接口及其实现 ReentrantReadWriteLock 方法 在 Java 并发编程中,锁机制是非常重要的一种同步机制,用于解决多线程之间的资源竞争问题。在 Java 中,有多种锁机制,如 ReentrantLock、...
【深入浅出ReentrantReadWriteLock源码解析】 ReentrantReadWriteLock是Java并发包中的一个核心类,它提供了读写锁的实现,使得多个线程可以并发读取共享资源,但写操作是互斥的,即同一时间只能有一个线程进行写...
Java的ReentrantReadWriteLock是Java并发包`java.util.concurrent.locks`中的一个重要工具,它提供了一种更细粒度的锁定机制,相比普通的独占锁(如ReentrantLock)在某些场景下能显著提高程序的并发性能。...
`ReentrantLock`和`ReentrantReadWriteLock`是Java并发包`java.util.concurrent.locks`中的两个重要工具,它们提供了比标准`synchronized`关键字更高级别的锁控制机制。本文将深入探讨这两个类,以及如何通过配置...
根据提供的文件信息,本文将详细解析读写锁`ReentrantReadWriteLock`以及`StampLock`在Java并发编程中的应用场景及其实现原理。 ### 一、读写锁介绍 #### 1.1 读写锁的基本概念 读写锁是一种特殊的锁机制,它可以...
5-4 Thread.join通信及其源码浅析.mp4 5-5 ThreadLocal的使用.mp4 5-6 Condition的使用.mp4 6-1 什么是原子类.mp4 6-2 原子更新基本类型.mp4 6-3 原子更新数组类型.mp4 6-4 原子地更新属性.mp4 6-5 原子更新...
5-4 Thread.join通信及其源码浅析.mp4 5-5 ThreadLocal的使用.mp4 5-6 Condition的使用.mp4 6-1 什么是原子类.mp4 6-2 原子更新基本类型.mp4 6-3 原子更新数组类型.mp4 6-4 原子地更新属性.mp4 6-5 原子更新...
5-4 Thread.join通信及其源码浅析.mp4 5-5 ThreadLocal的使用.mp4 5-6 Condition的使用.mp4 6-1 什么是原子类.mp4 6-2 原子更新基本类型.mp4 6-3 原子更新数组类型.mp4 6-4 原子地更新属性.mp4 6-5 原子更新...
5-4 Thread.join通信及其源码浅析.mp4 5-5 ThreadLocal的使用.mp4 5-6 Condition的使用.mp4 6-1 什么是原子类.mp4 6-2 原子更新基本类型.mp4 6-3 原子更新数组类型.mp4 6-4 原子地更新属性.mp4 6-5 原子更新...
5-4 Thread.join通信及其源码浅析.mp4 5-5 ThreadLocal的使用.mp4 5-6 Condition的使用.mp4 6-1 什么是原子类.mp4 6-2 原子更新基本类型.mp4 6-3 原子更新数组类型.mp4 6-4 原子地更新属性.mp4 6-5 原子更新...
- `ReentrantReadWriteLock`是Java提供的可重入的读写锁实现,它继承自`AbstractQueuedSynchronizer`(AQS)。可重入意味着一个线程可以多次获取同一锁,这在递归调用或者锁嵌套时很有用。 - **公平性**:`...
内容包括 01-并发编程之深入理解JMM&并发三大特性(一)-fox 02-并发编程之深入理解JMM&并发三...11-深入理解AQS之CyclicBarrier&ReentrantReadWriteLock详解-fox 12-深入理解AQS之ReentrantReadWriteLock详解-fox ...
6.5 深入理解 AQS之 ReentrantReadWritelock 实战副本.mp4
6.5 深入理解 AQS之 ReentrantReadWritelock 实战副本副本.mp4
ReentrantReadWriteLock 读写锁除了保证写操作对读操作可见性以及并发行提升外,简化了读写交互场景开发
2. **ReentrantReadWriteLock**:Java并发包(java.util.concurrent.locks)提供了`ReentrantReadWriteLock`,这是一个更精细的锁机制,支持读写分离。`ReadLock`允许多个读者同时访问,而`WriteLock`保证写操作的...