Java内存模型之原子性问题

本博客系列是学习并发编程过程中的记录总结。由于文章比较多，写的时间也比较散，所以我整理了个目录贴（传送门），方便查阅。

前言

之前的文章中讲到，jmm是内存模型规范在java语言中的体现。jmm保证了在多核cpu多线程编程环境下，对共享变量读写的原子性、可见性和有序性。

本文就具体来讲讲jmm是如何保证共享变量访问的原子性的。

原子性问题

原子性是指：一个或多个操作，要么全部执行且在执行过程中不被任何因素打断，要么全部不执行。

下面就是一段会出现原子性问题的代码：

public class atomicproblem {

    private static logger logger = loggerfactory.getlogger(atomicproblem.class);
    public static final int thread_count = 10;

    public static void main(string[] args) throws exception {
        bankaccount  sharedaccount = new bankaccount("account-csx",0.00);
        arraylist<thread> threads = new arraylist<>();
        for (int i = 0; i < thread_count; i++) {
            thread thread = new thread(new runnable() {
                @override
                public void run() {
                    for (int j = 0; j < 1000 ; j++) {
                        sharedaccount.deposit(10.00);
                    }
                }
            });
            thread.start();
            threads.add(thread);
        }
        for (thread thread : threads) {
            thread.join();
        }
        logger.info("the balance is:{}",sharedaccount.getbalance());
    }


    public static class bankaccount {
        private string accountname;

        public double getbalance() {
            return balance;
        }

        private double balance;

        public bankaccount(string accountname, double balance){
            this.accountname = accountname;
            this.balance =balance;
        }
        public double deposit(double amount){
            balance = balance + amount;
            return balance;
        }
        public double withdraw(double amount){
            balance = balance - amount;
            return balance;
        }
        public string getaccountname() {
            return accountname;
        }
        public void setaccountname(string accountname) {
            this.accountname = accountname;
        }
    }
}

上面的代码中开启了10个线程，每个线程会对共享的银行账户进行1000次存款操作，每次存款10块，所以理论上最后银行账户中的钱应该是10 * 1000 * 10 = 100000块。我执行了多次上面的代码，很多次最后的结果的确是100000，但是也有几次的结果并不是我们预期的。

14:40:25.981 [main] info com.csx.demo.spring.boot.concurrent.jmm.atomicproblem - the balance is:98260.0

出现上面结果的原因就是因为下面的操作并不是原子操作，其中的balance是一个共享变量。在多线程环境下可能会被打断。

balance = balance + amount;

上面的赋值操作被分为多步执行完成，下面简单解析下两个线程对balance同时加10的过程（模拟存款过程，假设balance的初始值还是0）

线程1从共享内存中加载balance的初始值0到工作内存
线程1对工作内存中的值加10

//此时线程1的cpu时间耗尽，线程2获得执行机会

线程2从共享内存中加载balance的初始值到工作内存，此时balance的值还是0
线程2对工作内存中的值加10，此时线程2工作内存中的副本值是10
线程2将balance的副本值刷新回共享内存，此时共享内存中balance的值是10

//线程2cpu时间片耗尽，线程1又获得执行机会
线程1将工作内存中的副本值刷新回共享内存，但是此时副本的值还是10，所以最后共享内存中的值也是10

上面简单模拟了一个原子性问题导致程序最终结果出错的过程。

jmm对原子性问题的保证

自带原子性保证

在java中，对基本数据类型的变量的读取和赋值操作是原子性操作。

a = true;  //原子性
a = 5;     //原子性
a = b;     //非原子性，分两步完成，第一步加载b的值，第二步将b赋值给a
a = b + 2; //非原子性，分三步完成
a ++;      //非原子性，分三步完成

synchronized

synchronized可以保证操作结果的原子性。synchronized保证原子性的原理也很简单，因为synchronized可以防止多个线程并发执行一段代码。还是用上面存款的场景做列子，我们只需要将存款的方法设置成synchronized的就能保证原子性了。

 public synchronized double deposit(double amount){
     balance = balance + amount; //1
     return balance;
 }

加了synchronized后，当一个线程没执行完deposit这个方法前，其他线程是不能执行这段代码的。其实我们发现synchronized并不能将上面的代码1编程原子性操作，上面的代码1还是有可能被中断的，但是即使被中断了其他线程也不能访问共享变量balance，当之前被中断的线程继续执行时得到的结果还是正确的。

因此synchronized对原子性问题的保证是从最终结果上来保证的，也就是说它只保证最终的结果正确，中间操作的是否被打断没法保证。这个和cas操作需要对比着看。

lock锁

public double deposit(double amount) {
    readwritelock.writelock().lock();
    try {
        balance = balance + amount;
        return balance;
    } finally {
        readwritelock.writelock().unlock();
    }
}

lock锁保证原子性的原理和synchronized类似，这边不进行赘述了。

原子操作类型

public static class bankaccount {
    //省略其他代码
    private atomicdouble balance;

    public double deposit(double amount) {
        return balance.addandget(amount);
    }
    //省略其他代码
}

jdk提供了很多原子操作类来保证操作的原子性。原子操作类的底层是使用cas机制的，这个机制对原子性的保证和synchronized有本质的区别。cas机制保证了整个赋值操作是原子的不能被打断的，而synchronized值能保证代码最后执行结果的正确性，也就是说synchronized能消除原子性问题对代码最后执行结果的影响。