并发编程：线程同步基础：7、StampedLock DEMO

目录

1、主程序

2、使用到的model类

1、主程序

package xyz.jangle.thread.test.n2_7.stampedlock;import java.util.concurrent.TimeUnit;import java.util.concurrent.locks.StampedLock;/** ** StampedLockDEMO*** @author jangle * @email jangle@jangle.xyz * @time 2020年7月26日 下午6:17:24 **/public class M {public static void main(String[] args) {StampedLock lock = new StampedLock();Position p = new Position(1, 2);cWriter(p, lock).start();cReader(p, lock).start();cOptimisticReader(p, lock).start();}/** *创建写线程，该线程使用了StampedLock的写锁 *使用 writeLock() 方法获取写锁 *使用 unlockWrite(stamp) 方法释放写锁 ** @author jangle * @time 2020年8月2日 下午2:59:41 * @param p * @param lock * @return */public static Thread cWriter(Position p, StampedLock lock) {return new Thread(() -> {for (int i = 0; i  {for (int i = 0; i  {long stamp;for (int i = 0; i < 100; i++) {try {//stamp = lock.tryOptimisticRead();Integer x = p.getX();Integer y = p.getY();if (lock.validate(stamp)) {System.out.println("乐观读：x:" + x + ",y:" + y);} else {System.out.println("OptimisticReader:" + stamp + " Not Free x:" + x + ",y:" + y);}TimeUnit.MILLISECONDS.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}});}/** * 其他方法说明 ** @author jangle * @time 2020年8月2日 下午3:25:28 * @param lock */public static void other(StampedLock lock) {// 尝试获取读锁，未获取返回0long stampR = lock.tryReadLock();//lock.tryReadLock(time, unit);// 尝试获取写锁，未获取返回0long stampW = lock.tryWriteLock();//lock.tryWriteLock(time, unit);// 尝试将读锁转换为写锁，失败返回0long newStampW = lock.tryConvertToWriteLock(stampR);// 尝试将写锁转换为读锁，失败返回0long newStampR = lock.tryConvertToReadLock(stampW);// 尝试转换为乐观读锁，失败返回0，成功则可使用这个stamp进行验证long optStampR = lock.tryConvertToOptimisticRead(stampR);// 验证获取乐观读stamp之后，到目前位置，操作的共享数据是否可用。boolean validate = lock.validate(optStampR);if(validate) {// 可用，进行相关操作}else {// 不可用， 进行其他操作}// 判断当前是读锁还是写锁lock.isReadLocked();lock.isWriteLocked();// 释放对应的锁lock.unlock(stampR);lock.unlock(stampW);lock.unlock(newStampR);lock.unlock(newStampW);}}

2、使用到的model类

package xyz.jangle.thread.test.n2_7.stampedlock;/** * StampedLock 的DEMO所要使用的共享数据类 * @author jangle * @email jangle@jangle.xyz * @time 2020年8月2日 下午1:55:09 **/public class Position {private Integer x, y;public Integer getX() {return x;}public void setX(Integer x) {this.x = x;}public Integer getY() {return y;}public void setY(Integer y) {this.y = y;}public Position(Integer x, Integer y) {super();this.x = x;this.y = y;}}