Java-JUC（三）：原子性变量与CAS算法

原子性

并发程序正确地执行，必须要保证原子性、可见性以及有序性。只要有一个没有被保证，就有可能会导致程序运行不正确。

原子性：一个操作或多个操作要么全部执行完成且执行过程不被中断，要么就不执行。

可见性：当多个线程同时访问同一个变量时，一个线程修改了这个变量的值，其他线程能够立即看得到修改的值。

有序性：程序执行的顺序按照代码的先后顺序执行。

对于单线程，在执行代码时jvm会进行指令重排序，处理器为了提高效率，可以对输入代码进行优化，它不保证程序中各个语句的执行先后顺序同代码中的顺序一致，但是它会保证保存最终执行结果和代码顺序执行的结果是一致的。

看下边的一个例子：

package com.dx.juc.test;

public class MyThread implements Runnable {
    private int serialNumber = 0;

    public void run() {
        System.out.println(Thread.currentThread().getName() + ":" + getSerialNumber());
    }

    public int getSerialNumber() {
        return serialNumber++;
    }
}

调用：

package com.dx.juc.test;

public class Main {
    public static void main(String[] args) {
        MyThread thread=new MyThread();
        for(int i=0;i<10;i++){
            new Thread(thread).start();
        }
    }
}

输出结果（有时会抛出下边异常结果，但不是每次都出现异常结果）：

Thread-1:0
Thread-3:2
Thread-2:1
Thread-0:0
Thread-4:3
Thread-5:4
Thread-7:5
Thread-6:6
Thread-9:7
Thread-8:8

上边这个操作错误的原因：

1）初始值serialNumer=0，thread-0把该值复制到自己的工作空间（线程私有的，该工作空间也可以叫做缓存），之后进行了三个操作：

操作一：int temp=serialNumber;// 从主存中将serialNumber复制到自己的工作空间

操作二：serialNumber=serialNumber+1;// 在自己的工作空间内进行运算

操作三：将serialNumber刷新到主存中

2）假设thread-0在操作三还未处理之前，thread-1从主存中复制serialNumber=0到自己的工作空间，然后thread-0触发操作三，而此时thread-1并不知道主存中的serialNumber已经被修改，它依然使用工作空间中的serialNum=0，也进行与thread-0一样的散步操作。

当thread-1触发操作三时（此时thread-0已经把主存中的serialNubmer修改为1）并不知道serialNumber是否被其他线程操作过，它就把在自己工作区修改的结果刷新到主存中，此时thread-1中的serialNum=1，之后的操作就是thread-1的值覆盖了thread-0的值，实际上他们值是一样的。

3）即时把int serialNumber添加上volatile修饰也不能避免该问题，从这里可以看出volatile是不具有原子性的。

在java中，对基本数据类型的变量的读取和赋值操作是原子性操作，即这些操作是不可被中断，要么执行，要么不执行。

X=10;   // 原子性（简单的读取、将数字赋值给变量）
Y = x;  // 变量之间的相互赋值，不是原子操作
X++;    // 对变量进行计算操作，此时讲过三次操作int temp=X;X=X+1;X=temp,经过获取、修改、赋值三个操作。
X = x+1;

语句2实际包括两个操作，它先要去读取x的值，再将y值写入，两个操作分开是原子性的，合在一起就不是原子性的。

语句3、4:x++ x=x+1包括3个操作：读取x的值，x+1，将x写入，所以他们也不是原子性的。

只有语句1具有原子性。

注：可以通过synchronized和Lock实现原子性。因为synchronized和Lock能够保证任一时刻只有一个线程访问该代码块。

使用Atomic解决原子性问题

在jdk1.5以后java.util.concurrent.atomic包下，提供了

大量的原子变量，它们内部使用CAS算法。

针对上边的代码修改为如下：

package com.dx.juc.test;

import java.util.concurrent.atomic.AtomicInteger;

public class MyThread implements Runnable {
    private AtomicInteger serialNumber = new AtomicInteger();

    public void run() {
        System.out.println(Thread.currentThread().getName() + ":" + getSerialNumber());
    }

    public int getSerialNumber() {
        return serialNumber.getAndIncrement();
    }
}

将int serialNumber修改AtomicInteger serialNumber就具有原子性，也不在出现异常结果。

CAS算法

CAS（Compare-And-Swap）是一种硬件对并发的支持，针对多处理器操作而设计的，处理器中的一种特殊指令，用于管理对共享数据的并发访问。

CAS是一种无锁的非阻塞算法实现，是硬件对于并发操作的支持，保证了数据变量的原子性。

Cas包含了3个操作数：

内存值 V
预估值 A
更新值 B

当且仅当 V == A 时， V = B; 否则，不会执行任何操作。

简单的来说，CAS有3个操作数，要读写的内存值V，旧的预期值A，要修改的新值B。当且仅当预期值A和内存值V相同时，将内存值V修改为B，否则返回V（不做任何操作，然后重新获取主存V值，重新操作。）。这是一种乐观锁的思路，它相信在它修改之前，没有其它线程去修改它。

Java-JUC（三）：原子性变量与CAS算法

原子性

使用Atomic解决原子性问题

CAS算法

相关推荐