Java 并发编程(二)：如何保证共享变量的原子性？

线程安全性是咱们在进行 Java 并发编程的时候必需要先考虑清楚的一个问题。这个类在单线程环境下是没有问题的，那么咱们就能确保它在多线程并发的状况下表现出正确的行为吗？

我这我的，在没有副业以前，一心扑在工做上面，因此处理的蛮驾轻就熟，心态也一直保持的不错；但有了副业以后，心态就变得像坐过山车同样。副业收入超过主业的时候，人特别亢奋，像打了鸡血同样；副业迟迟打不开局面的时候，人就变得惶惶不可终日。

仿佛我就只能是个单线程，副业和主业并行开启多线程模式的时候，我就变得特别没有安全感，尽管总体的收入比没有副业以前有了很大的改善。

怎么让我本身变得有安全感，我还没想清楚（你要是有好的方法，请必定要告诉我）。但怎么让一个类在多线程的环境下是安全的，有 3 条法则，让我来告诉你：

一、不在线程之间共享状态变量。
二、将状态变量改成不可变。
三、访问状态变量时使用同步。

那你可能要问，状态变量是什么？

咱们先来看一个没有状态变量的类吧，代码示例以下。

class Chenmo {
    public void write() {
        System.out.println("我寻了半生的春天，你一笑即是了。");
    }
}

Chenmo 这个类就是无状态变量的，它只有一个方法，既没有成员变量，也没有类变量。任何访问它的线程都不会影响另一个线程的结果，由于两个线程之间没有共享任何的状态变量。因此能够下这样一个结论：无状态变量的类必定是线程安全的。

而后咱们再来看一个有状态变量的类。假设沉默（Chenmo 类）每写一行字（write() 方法），就要作一次统计，这样好找出版社索要稿费。咱们为 Chenmo 类增长一个统计的字段，代码示例以下。

class Chenmo {
    private long count = 0;
    public void write() {
        System.out.println("我寻了半生的春天，你一笑即是了。");
        count++;
    }
}

Chenmo 类在单线程环境下是能够准确统计出行数的，但多线程的环境下就不行了。由于递增运算 count++ 能够拆分为三个操做：读取 count，将 count 加 1，将计算结果赋值给 count。多线程的时候，这三个操做发生的时序多是混乱的，最终统计出来的 count 值就会比预期的值小。

PS：具体的缘由能够回顾上一节《Java 并发编程(一)：摩拳擦掌》。

写做不易，咱不能亏待了沉默，对不对？那就想点办法吧。

假定线程 A 正在修改 count 变量，这时候就要防止线程 B 或者线程 C 使用这个变量，从而保证线程 B 或者线程 C 在使用 count 的时候是线程 A 修改事后的状态。

怎么防止呢？能够在 write() 方法上加一个 synchronized 关键字。代码示例以下。

class Chenmo {
    private long count = 0;
    public synchronized void write() {
        System.out.println("我寻了半生的春天，你一笑即是了。");
        count++;
    }
}

关键字 synchronized 是一种最简单的同步机制，能够确保同一时刻只有一个线程能够执行 write()，也就保证了 count++ 在多线程环境下是安全的。

在编写并发应用程序时，咱们必需要保持一种正确的观念，那就是——首先要确保代码可以正确运行，而后再是如何提升代码的性能。

但众所周知，synchronized 的代价是昂贵的，多个线程之间访问 write() 方法是互斥的，线程 B 访问的时候必需要等待线程 A 访问结束，这没法体现出多线程的核心价值。

java.util.concurrent.atomic.AtomicInteger 是一个提供原子操做的 Integer 类，它提供的加减操做是线程安全的。因而咱们能够这样修改 Chenmo 类，代码示例以下。

class Chenmo {
    private AtomicInteger count = new AtomicInteger(0);
    public void write() {
        System.out.println("我寻了半生的春天，你一笑即是了。");
        count.incrementAndGet();
    }
}

write() 方法再也不须要 synchronized 关键字保持同步，因而多线程之间就再也不须要以互斥的方式来调用该方法，能够在必定程度上提高统计的效率。

某一天，出版社统计稿费的形式变了，不只要统计行数，还要统计字数，因而 Chenmo 类就须要再增长一个成员变量了。代码示例以下。

class Chenmo {
    private AtomicInteger lineCount = new AtomicInteger(0);
    private AtomicInteger wordCount = new AtomicInteger(0);
    public void write() {
        String words = "我这一生，走过许多地方的路，行过许多地方的桥，看过许屡次的云，喝过许多种类的酒，却只爱过一个正当年龄的人。";
        System.out.println(words);
        lineCount.incrementAndGet();
        wordCount.addAndGet(words.length());
    }
}

你以为这段代码是线程安全的吗？

结果显而易见，这段代码不是线程安全的。由于 lineCount 和 wordCount 是两个变量，尽管它们各自是线程安全的，但线程 A 进行 lineCount 加 1 的时候，并不可以保证线程 B 是在线程 A 执行完 wordCount 统计后开始 lineCount 加 1 的。

该怎么办呢？方法也很简单，代码示例以下。

class Chenmo {
    private int lineCount = 0;
    private int wordCount = 0;
    public void write() {
        String words = "我这一生，走过许多地方的路，行过许多地方的桥，看过许屡次的云，喝过许多种类的酒，却只爱过一个正当年龄的人。";
        System.out.println(words);
        
        synchronized (this) {
            lineCount++;
            wordCount++;
        }
    }
}

对行数统计（lineCount++）和字数统计（wordCount++）的代码进行加锁，保证这两行代码是原子性的。也就是说，线程 B 在进行统计的时候，必需要等待线程 A 统计完以后再开始。

synchronized (lock) {...} 是 Java 提供的一种简单的内置锁机制，用于保证代码块的原子性。线程在进入加锁的代码块以前自动获取锁，而且退出代码块的时候释放锁，能够保证一组语句做为一个不可分割的单元被执行。

---

上一篇：Java 并发编程(一)：简介

下一篇：如何保证共享变量的原子性？

微信搜索「沉默王二」公众号，关注后回复「免费视频」获取 500G 高质量教学视频（已分门别类）。