您当前的位置:首页 > 电脑百科 > 程序开发 > 语言 > JAVA

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

时间:2019-09-17 10:22:44  来源:  作者:

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

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

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

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

  1. 不在线程之间共享状态变量
  2. 将状态变量改为不可变
  3. 访问状态变量时使用同步
Java 并发编程:如何保证共享变量的原子性?

 

01 那么,状态变量是什么?

我们先来看一个没有状态变量的类吧,代码示例如下。

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 值就会比预期的值小。

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

02 怎么防止呢?

可以在 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());
 }
}

03 你觉得这段代码是线程安全的吗?

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

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

 

04 该怎么办呢?

方法也很简单,代码示例如下。

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 统计完之后再开始。

原文链接:https://juejin.im/post/5d7ee216e51d4561af16ddb2

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



Tags:Java 并发编程   点击:()  评论:()
声明:本站部分内容及图片来自互联网,转载是出于传递更多信息之目的,内容观点仅代表作者本人,如有任何标注错误或版权侵犯请与我们联系(Email:2595517585@qq.com),我们将及时更正、删除,谢谢。
▌相关推荐
线程安全性是我们在进行 Java 并发编程的时候必须要先考虑清楚的一个问题。这个类在单线程环境下是没有问题的,那么我们就能确保它在多线程并发的情况下表现出正确的行为吗?我...【详细内容】
2019-09-17  Tags: Java 并发编程  点击:(167)  评论:(0)  加入收藏
▌简易百科推荐
面向对象的特征之一封装 面向对象的特征之二继承 方法重写(override/overWrite) 方法的重载(overload)和重写(override)的区别: 面向对象特征之三:多态 Instanceof关键字...【详细内容】
2021-12-28  顶顶架构师    Tags:面向对象   点击:(2)  评论:(0)  加入收藏
一、Redis使用过程中一些小的注意点1、不要把Redis当成数据库来使用二、Arrays.asList常见失误需求:把数组转成list集合去处理。方法:Arrays.asList 或者 Java8的stream流式处...【详细内容】
2021-12-27  CF07    Tags:Java   点击:(3)  评论:(0)  加入收藏
文章目录 如何理解面向对象编程? JDK 和 JRE 有什么区别? 如何理解Java中封装,继承、多态特性? 如何理解Java中的字节码对象? 你是如何理解Java中的泛型的? 说说泛型应用...【详细内容】
2021-12-24  Java架构师之路    Tags:JAVA   点击:(5)  评论:(0)  加入收藏
大家好!我是老码农,一个喜欢技术、爱分享的同学,从今天开始和大家持续分享JVM调优方面的经验。JVM调优是个大话题,涉及的知识点很庞大 Java内存模型 垃圾回收机制 各种工具使用 ...【详细内容】
2021-12-23  小码匠和老码农    Tags:JVM调优   点击:(12)  评论:(0)  加入收藏
前言JDBC访问Postgresql的jsonb类型字段当然可以使用Postgresql jdbc驱动中提供的PGobject,但是这样在需要兼容多种数据库的系统开发中显得不那么通用,需要特殊处理。本文介绍...【详细内容】
2021-12-23  dingle    Tags:JDBC   点击:(13)  评论:(0)  加入收藏
Java与Lua相互调用案例比较少,因此项目使用需要做详细的性能测试,本内容只做粗略测试。目前已完成初版Lua-Java调用框架开发,后期有时间准备把框架进行抽象,并开源出来,感兴趣的...【详细内容】
2021-12-23  JAVA小白    Tags:Java   点击:(11)  评论:(0)  加入收藏
Java从版本5开始,在 java.util.concurrent.locks包内给我们提供了除了synchronized关键字以外的几个新的锁功能的实现,ReentrantLock就是其中的一个。但是这并不意味着我们可...【详细内容】
2021-12-17  小西学JAVA    Tags:JAVA并发   点击:(11)  评论:(0)  加入收藏
一、概述final是Java关键字中最常见之一,表示“最终的,不可更改”之意,在Java中也正是这个意思。有final修饰的内容,就会变得与众不同,它们会变成终极存在,其内容成为固定的存在。...【详细内容】
2021-12-15  唯一浩哥    Tags:Java基础   点击:(17)  评论:(0)  加入收藏
1、问题描述关于java中的日志管理logback,去年写过关于logback介绍的文章,这次项目中又优化了下,记录下,希望能帮到需要的朋友。2、解决方案这次其实是碰到了一个问题,一般的情况...【详细内容】
2021-12-15  软件老王    Tags:logback   点击:(19)  评论:(0)  加入收藏
本篇文章我们以AtomicInteger为例子,主要讲解下CAS(Compare And Swap)功能是如何在AtomicInteger中使用的,以及提供CAS功能的Unsafe对象。我们先从一个例子开始吧。假设现在我们...【详细内容】
2021-12-14  小西学JAVA    Tags:JAVA   点击:(22)  评论:(0)  加入收藏
最新更新
栏目热门
栏目头条