CAS是乐观锁技术,当多个线程尝试使用CAS同时更新同一个变量时,只有其中一个线程能更新变量的值,而其它线程都失败,失败的线程并不会被挂起,而是被告知这次竞争中失败,并可以再次尝试。
CAS 操作中包含三个操作数 —— 需要读写的内存位置(V)、进行比较的预期原值(A)和拟写入的新值(B)。如果内存位置V的值与预期原值A相匹配,那么处理器会自动将该位置值更新为新值B。否则处理器不做任何操作。无论哪种情况,它都会在 CAS 指令之前返回该位置的值。(在 CAS 的一些特殊情况下将仅返回 CAS 是否成功,而不提取当前值。)CAS 有效地说明了“ 我认为位置 V 应该包含值 A;如果包含该值,则将 B 放到这个位置;否则,不要更改该位置,只告诉我这个位置现在的值即可。 ”这其实和乐观锁的冲突检查+数据更新的原理是一样的。
强调一下,乐观锁是一种思想。CAS是这种思想的一种实现方式。
结合CAS和volatile可以实现无锁并发,适用于线程数少,多核CPU场景下
JUC并发包提供了
以AtomicInteger为例
public static void main(String[] args){
AtomicInteger i = new AtomicInteger(3);
System.out.println(i.incrementAndGet()); // ++i
System.out.println(i.getAndIncrement()); // i++
System.out.println(i.addAndGet(12)); //先加后取值
System.out.println(i.getAndAdd(12)); //先取值后加
System.out.println(i.get());
// 读取到 设置值
System.out.println(i.updateAndGet(x -> x * 10));
}
public class getClassTest {
static AtomicReference<String> ref = new AtomicReference<>("A");
public static void main(String[] args) {
System.out.println("main start...");
String prev = ref.get();
other();
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName() + ": A -> C " + ref.compareAndSet("A", "C"));
}
public static void other() {
new Thread(() -> {
System.out.println(Thread.currentThread().getName() + ": A -> B " + ref.compareAndSet("A", "B"));
}, "t1").start();
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
new Thread(() -> {
System.out.println(Thread.currentThread().getName() + ": B -> A " + ref.compareAndSet("B", "A"));
}, "t2").start();
}
}
主线程仅能判断出共享变量的值与最初值A是否相同,不能感知到这种从A改为B又改回A的情况,如果主线程希望:
只要有其他线程 动过了 共享变量,那么自己的cas就算失败,这时,仅比较值是不够的,需要再加一个版本号
public class getClassTest {
static AtomicStampedReference<String> ref = new AtomicStampedReference<>("A", 0);
public static void main(String[] args) {
System.out.println("main start...");
//获取值A
String prev = ref.getReference();
//获取版本号
int stamp = ref.getStamp();
System.out.println(Thread.currentThread().getName() + " stamp : " + stamp);
other();
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName() +" stamp : "+ stamp);
System.out.println(Thread.currentThread().getName() + ": A -> C " + ref.compareAndSet(prev, "C", stamp, stamp + 1));
}
public static void other() {
new Thread(() -> {
int stamp = ref.getStamp();
System.out.println(Thread.currentThread().getName() + " stamp : " + stamp);
System.out.println(Thread.currentThread().getName() + ": A -> B " + ref.compareAndSet(ref.getReference(), "B", stamp, stamp + 1));
}, "t1").start();
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
new Thread(() -> {
int stamp = ref.getStamp();
System.out.println(Thread.currentThread().getName() + " stamp : " + stamp);
System.out.println(Thread.currentThread().getName() + ": B -> A " + ref.compareAndSet(ref.getReference(), "A", stamp, stamp + 1));
}, "t2").start();
}
}
手机扫一扫
移动阅读更方便
你可能感兴趣的文章