网站 not found,企业邮箱什么意思,钓鱼网站网址大全,百度极速版免费下载安装1、主要方法
.readLock().lock();获取读锁 读锁之间互不干扰。
.writeLock().lock();获取写锁 写锁可以锁定住读锁和其他写操作。
2、主程序
package xyz.jangle.thread.test.n2_5.rwlock;import java.util.concurrent.TimeUnit;/*** * 读写锁。ReentrantReadWriteLock* a…1、主要方法
.readLock().lock();获取读锁 读锁之间互不干扰。
.writeLock().lock();获取写锁 写锁可以锁定住读锁和其他写操作。
2、主程序
package xyz.jangle.thread.test.n2_5.rwlock;import java.util.concurrent.TimeUnit;/*** * 读写锁。ReentrantReadWriteLock* author jangle* email janglejangle.xyz* time 2020年7月22日 下午9:37:18* */
public class M {public static void main(String[] args) {RWInfo rwInfo new RWInfo();// 读取价格1的线程new Thread(() - {for (int i 0; i 20; i) {rwInfo.getPrice1();try {TimeUnit.MILLISECONDS.sleep(500);} catch (InterruptedException e) {e.printStackTrace();}}}).start();// 读取价格2的线程new Thread(() - {for (int i 0; i 20; i) {rwInfo.getPrice2();try {TimeUnit.MILLISECONDS.sleep(500);} catch (InterruptedException e) {e.printStackTrace();}}}).start();// 修改价格1和价格2的线程new Thread(() - {for (int i 0; i 3; i) {rwInfo.setPrice1(rwInfo.getPrice1() 1, rwInfo.getPrice2()1);}}).start();}}3、读写锁实体
package xyz.jangle.thread.test.n2_5.rwlock;import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;/*** * 读写锁实体类* author jangle* email janglejangle.xyz* time 2020年7月22日 下午9:26:57* */
public class RWInfo {private double price1, price2;private ReadWriteLock RWLock;public RWInfo() {super();this.price1 1.0;this.price2 2.0;RWLock new ReentrantReadWriteLock();}public double getPrice1() {RWLock.readLock().lock();double v price1; // 赋值给中间变量然后释放锁。System.out.println(读价格1信息v);RWLock.readLock().unlock();return v;}// 读锁之间互不干扰public double getPrice2() {RWLock.readLock().lock();double v price2;System.out.println(读价格2信息v);RWLock.readLock().unlock();return v;}/*** 写锁可以锁定住读锁和其他的写操作。 * * author jangle* time 2020年7月22日 下午9:35:11* param price1* param price2*/public void setPrice1(double price1, double price2) {RWLock.writeLock().lock();System.out.println(开始修改价格);this.price1 price1;this.price2 price2;try {// 睡眠3秒让读锁锁定其他的读写操作TimeUnit.SECONDS.sleep(3);} catch (InterruptedException e) {e.printStackTrace();}RWLock.writeLock().unlock();}}
