乐观锁
作者:互联网
乐观锁有版本号、CAS两种实现方式。
1.
下面演示原子引用解决CAS带来的ABA问题,其实使用了乐观锁的版本号的思想:
package com.cas;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicStampedReference;
/**
* @author QLBF
* @version 1.0
* @date 2021/5/23 11:27
*/
public class ABASolve {
//AtomicStampedReference 注意,如果泛型是一个包装类,注意对象的引用问题
// 正常在业务操作,这里面比较的都是一个个对象,这里初始值为10,版本也为1
static AtomicStampedReference<Integer> atomicStampedReference=new AtomicStampedReference<>(10,1);
// CAS compareAndSet : 比较并交换!
public static void main(String[] args) {
new Thread(()->{
int stamp = atomicStampedReference.getStamp();
System.out.println("a1原始版本号:"+stamp);
try {
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
//atomicStampedReference.getStamp()为期待版本号
System.out.println(atomicStampedReference.compareAndSet(10, 11,
atomicStampedReference.getStamp(), atomicStampedReference.getStamp() + 1));
System.out.println("a2的版本号:"+atomicStampedReference.getStamp());
System.out.println(atomicStampedReference.compareAndSet(11, 10,
atomicStampedReference.getStamp(), atomicStampedReference.getStamp() + 1));
System.out.println("a3的版本号:"+atomicStampedReference.getStamp());
},"a").start();
new Thread(()->{
int stamp = atomicStampedReference.getStamp();
System.out.println("b原始版本号:"+stamp);
//这里必要加,否则就是a2,a3改不了
try {
TimeUnit.SECONDS.sleep(2);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(atomicStampedReference.compareAndSet(10,66,
stamp,stamp+1));
System.out.println("b2的版本号:"+atomicStampedReference.getStamp());
},"b").start();
}
}
这时b2想改,但是版本号不一样,就改不了。这里要注意延时,因为这是普通方法(没有synchronized等锁的),所以a演示就到b进去了,然后b又演示又到a执行完a3再回到b2
标签:版本号,System,乐观,getStamp,println,atomicStampedReference,out 来源: https://blog.csdn.net/GLOAL_COOK/article/details/117192055