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

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

我这个人,在没有副业之前,一心扑在工作上面,所以处理的蛮得心应手,心态也一直保持的不错;但有了副业之后,心态就变得像坐过山车一样。副业收入超过主业的时候,人特别亢奋,像打了鸡血一样;副业迟迟打不开局面的时候,人就变得惶惶不可终日。

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

怎么让我自己变得有安全感,我还没想清楚(你要是有好的方法,请一定要告诉我)。但怎么让一个类在多线程的环境下是安全的,有 3 条法则,让我来告诉你:

1、不在线程之间共享状态变量。
2、将状态变量改为不可变。
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 并发编程(一):摩拳擦掌

PS:原创不易,喜欢就点个赞,这将是我最强的写作动力。如果你觉得我写的文章对你有帮助,也蛮有趣的,就关注一下我的公众号「回复关键字“java”,可领取 Java 程序员进阶必读资料包」,谢谢。

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 225,124评论 6 523
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 96,453评论 3 404
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 172,386评论 0 368
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 61,136评论 1 301
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 70,142评论 6 400
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 53,593评论 1 315
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 41,958评论 3 429
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 40,944评论 0 279
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 47,477评论 1 324
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 39,512评论 3 346
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 41,639评论 1 355
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 37,227评论 5 351
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 42,971评论 3 340
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 33,397评论 0 25
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 34,550评论 1 277
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 50,203评论 3 381
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 46,713评论 2 366

推荐阅读更多精彩内容