标签:中比 执行流程 equal stat 其他 cin 线程优先级 catch 成功
一 概念
在计算机中比较和交换(Conmpare And Swap 即 CAS)是用于实现多线程同步的原子指令,当多个线程对某个资源进行CAS操作,只能有1个线程成功,其他线程并不会阻塞而是返回失败信号。
二 基本原理
每个CAS包含3个运算符
1 内存地址 V
2 旧的预期值A
3 新增B
基本思路,如果V地址上的值和传入的旧的期望值A相等,就给地址赋个新值B,否则不做任何处理
if(V.value.equals(A))
{
V.value = B;
return true;
}else
{
return false;
}
常用 原子操作类型
基本类型 AtomicInteger,AtomicLong,AtomicBoolean;
数组类型 AtomicIntegerArray,AtomicLongArray,AtomicReferenceArray;
引用类型 AtomicReference,AtomicMarkableReference,AtomicStampedReference
三 常见用法和ABA问题
3.1 常见用法
原子操作基本类型(Integer)
AtomicInteger atomicInteger = new AtomicInteger(10);
//基本类型原子操作测试
public void atomicIntegerTest()
{
//自增1 并返回新值
System.out.println("自增 并返回新值="+atomicInteger.incrementAndGet());
//返回旧值,再加1
System.out.println("返回 ="+ atomicInteger.getAndIncrement()+" 并自增");
}
结果
自增 并返回新值=11
返回=11 并自增
用途 比如可以用于多线程的计数等,
//原子操作类型数组
int [] arr = new int[]{1,2,3,4,5,6,7,8};
private  AtomicIntegerArray atomicArray = new AtomicIntegerArray(arr);
@Test
public  void test()
{
    //获取索引为0的值,并修改索引0里的值为3
    System.out.println(atomicArray.getAndSet(0,3));
    System.out.println("原数组索引0的值="+arr[0]);
    System.out.println("原子类型数组里索引0的值="+atomicArray.get(0));
}
结果
1
原数组索引0的值=1
原子类型数组里索引0的值 = 3;
3.2 ABA问题
原来V地址上值为A
1. 时刻1 线程1 执行读取操作,获取原值A,然后线程被切换走了 
2. 时刻2   线程2 更新了V上的值为B
3. 时刻3   线程2 更新了V上的值为A
4. 时刻4   线程1恢复运行,将比较值(compareValue)与原值(oldValue)进行比较,发现两个值相等(都是A)。
然后用新值(newValue)B 写入内存中,完成 CAS 操作
我们可以发现,其实V值,在线程1修改之前,已经被修改过2次了(改为B,又改回A)
但线程1并不知道原值被修改,所以继续执行流程。
处理ABA问题
      通常是对每一次CAS操作设置版本戳,目前java.util.concurrent.atomic包下提供2种原子类
AtomicMarkableReference                                                                          AtomicStampedReference
版本戳是 boolean 类型 版本戳是number类型
只关心数据是否被动过 关心数据被动过几次
看具体示例
public class AtomicStampedRefernceTest {
    //带版本戳的原子操作
    private static AtomicStampedReference<String> atomicStampedReference = new AtomicStampedReference<>("作者", 1);
    //旧的版本戳
    final int oldstamp = atomicStampedReference.getStamp();
    //旧值
    final String oldValue = atomicStampedReference.getReference();
    @Test
    public void mainTest() {
        Thread right = new Thread(new rightThread());
        //正确版本号线程
        //错误版本号线程
        Thread error =  new Thread(new errorThread());
        try {
            right.start();
            right.join();
            error.start();
            error.join();
        }catch (InterruptedException ex)
        {
            ex.printStackTrace();
        }
    }
    //正确使用了版本号进行了CAS的线程
    public class rightThread implements Runnable {
        @Override
        public void run() {
            String value = atomicStampedReference.getReference();
            int stamp = atomicStampedReference.getStamp();
            Thread.currentThread().setName("正确使用了版本号线程");
            System.out.println(Thread.currentThread().getName() + ":值=" + value + ",版本戳=" + stamp + " CAS结果=" +
                    atomicStampedReference.compareAndSet(value, value + "-帅哥", stamp, stamp + 1));
        }
    }
    //错误使用了版本号进行了CAS的线程
    public class errorThread implements Runnable {
        @Override
        public void run() {
            String value = atomicStampedReference.getReference();
            int stamp = atomicStampedReference.getStamp();
            Thread.currentThread().setName("错误使用了版本号线程");
            System.out.println(Thread.currentThread().getName() + ":值=" + value + ",版本戳=" + stamp + " CAS结果=" +
                    atomicStampedReference.compareAndSet(value, value + "-老者", oldstamp, oldstamp + 1));
        }
    }
}
输出结果
正确使用了版本号线程:值=作者,版本戳=1 CAS结果=true
错误使用了版本号线程:值=作者-帅哥,版本戳=2 CAS结果=false
总结:
CAS和synchronized有什么区别?
    synchronized是java的内置锁,目的是用于锁住某块资源,确保这块资源只能被一个线程访问(即确保资源的原子性),是悲观锁。
    CAS是计算机指令级别的一个原子操作
使用synchronized 有什么不方便的地方或者弊端?
    1  synchronized 是基于阻塞机制,如果某个线程拿不到锁会阻塞在那里,当被阻塞的线程优先级很高时,我们无法中断
    2  拿到锁的线程一直不释放怎么办
    3 大量竞争锁,会出现死锁或活锁,而且会消耗CPU,以及其他一些安全问题
使用CAS的弊端
    为了确保CAS操作成功,你要死循环调用,直到成功为止,造成CPU开销问题
什么情况下用CAS?
    当觉得用锁不方便,或者太笨重时,可以考虑用CAS 
标签:中比 执行流程 equal stat 其他 cin 线程优先级 catch 成功
原文地址:https://www.cnblogs.com/hup666/p/11871403.html