并发编程-04线程安全性之原子性Atomic包的4种类型详解

简介: 并发编程-04线程安全性之原子性Atomic包的4种类型详解

2019080611330380.jpg




线程安全性文章索引


并发编程-03线程安全性之原子性(Atomic包)及原理分析

并发编程-04线程安全性之原子性Atomic包的4种类型详解

并发编程-05线程安全性之原子性【锁之synchronized】

并发编程-06线程安全性之可见性 (synchronized + volatile)

并发编程-07线程安全性之有序性


脑图



20190216205207715.png



概述


在实际应用中,当我们更新一个变量时,在并发环境下,如果多个线程同时去更新这个变量,更新后的值可能不是我们期望的值。

如果理解Java内存模型 JMM的原理的话,上面这个结论就很容易理解了。可参考下前面写的这篇文章

并发编程-02并发基础CPU多级缓存和Java内存模型JMM


20190217104648337.png



举个例子:

【多线程场景】假设有个变量a在主内存中的初始值为1,线程A和线程B同时从主内存中获取到了a的值,线程A更新a+1,线程B也更新a+1,经过线程AB更新之后可能a不等于3,而是等于2。因为A和B线程在更新变量a的时候从主内存中拿到的a都是1,而不是等A更新完刷新到主内存后,线程B再从主内存中取a的值去更新a,所以这就是线程不安全的更新操作.


解决办法


使用锁 1. 使用synchronized关键字synchronized会保证同一时刻只有一个线程去更新变量. 2、Lock接口【篇幅原因先不讨论synchronized和lock,另开篇介绍】

使用JDK1.5开始提供的java.util.concurrent.atomic包,该包中的原子操作类提供了一种用法简单、性能高效、线程安全地更新一个变量的方式。

这里我们使用的JDK版本JDK8


原子更新基本类型


使用原子的方式更新基本类型,Atomic包提供了以下3个类。

  • AtomicBoolean:原子更新布尔类型
  • AtomicInteger:原子更新整型
  • AtomicLong:原子更新长整型

以AtomicInteger为例看下JDK8源码中提供的方法


20190217110318196.png


列举几个常用的方法:


int addAndGet(int delta):以原子方式将输入的数值与实例中的值(AtomicInteger里的 value)相加,并返回结果

boolean compareAndSet(int expect,int update):如果输入的数值等于预期值,则以原子方式将该值设置为输入的值

int getAndIncrement():以原子方式将当前值加1,注意,这里返回的是自增前的值

int incrementAndGet():以原子方式将当前值加1,注意,这里返回的是自增后的值

void lazySet(int newValue):最终会设置成newValue,使用lazySet设置值后,可能导致其他线程在之后的一小段时间内还是可以读到旧的值


Demo

package com.artisan.example.atomic;
import java.util.concurrent.atomic.AtomicInteger;
import lombok.extern.slf4j.Slf4j;
@Slf4j
public class AtomicIntegerDemo {
  // 实例化一个初始值为5的AtomicInteger
  private static AtomicInteger value = new AtomicInteger(5);
  public static void main(String[] args) {
    // 以原子方式将输入的数值与value 相加,并返回结果 
    log.info("value的值:{}" ,value.addAndGet(3));
    // 获取value的值
    log.info("value的值:{}",value.get());
    // 如果输入的数值等于预期值,则以原子方式将该值设置为输入的值
    log.info("执行结果:{}" ,value.compareAndSet(8, 11)); // 因为经过了addAndGet,操作之前value的值为8,这里会将value更新成11,返回true
    log.info("执行结果:{}" ,value.compareAndSet(5, 11)); // 因为经过了addAndGet,操作之前value的值为8,并不等于5,因此不会更新为11,返回false
    log.info("value的值:{}" ,value.get());
    log.info("value 增长前的值:{}",value.getAndIncrement());
    log.info("value的值:{}" ,value.get());
    log.info("value 增长后的值:{}",value.incrementAndGet());
    log.info("value的值:{}" ,value.get());
    //  最终会设置成newValue,使用lazySet设置值后,可能导致其他线程在之后的一小段时间内还是可以读到旧的值
    value.lazySet(99);
    log.info("lazyset value: {}",value.get());
  }
}


执行结果:


2019021711453823.png

AtomicBoolean 场景举例


假设流程中的某个方法只能执行一次初始化操作, 我们可以设置个flag, 使用AtomicBoolean去更新flag的值,执行方法前调用compareAndSet方法来判断如果该值为flase,更新为true,并执行该方法。 因为是线程安全的,所以后续的访问flag均为true,不满足if条件,所以均不会执行该方法。


package com.artisan.example.atomic;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaphore;
import java.util.concurrent.atomic.AtomicBoolean;
import lombok.extern.slf4j.Slf4j;
@Slf4j
public class AtomicBooleanDemo {
  //总请求数
  private static int clientTotal = 5000;
  // 同一时间允许执行的线程数
  private static int threadTotal = 200;
  // 标识  ,使用原子包中的AtomicBoolean  初始化为false
  private static AtomicBoolean atomicBooleanFlag = new AtomicBoolean(false);
  public static void main(String[] args) throws Exception {
    // 线程池
    ExecutorService executorService = Executors.newCachedThreadPool();
    // 信号量 同一时间允许threadTotal个请求同时执行 即初始化threadTotal个信号量
    Semaphore semaphore = new Semaphore(threadTotal);
    //定义clientTotal个线程需要执行完,主线程才能继续执行
    CountDownLatch countDownLatch = new CountDownLatch(clientTotal);
    // 循环
    for (int i = 0; i < clientTotal; i++) {
      executorService.execute(() ->{
        try {
          semaphore.acquire();
          doSomething();
          semaphore.release();
        } catch (InterruptedException e) {
          e.printStackTrace();
        }
        // 减一
        countDownLatch.countDown();
      });
    }
    // 当全部线程都调用了countDown方法,count的值等于0,然后主线程就能通过await()方法,恢复执行自己的任务。
    countDownLatch.await();
    // 关闭线程池
    executorService.shutdown();
    log.info("flag:{}" ,atomicBooleanFlag.get());
  }
  private static void doSomething() {
    // 如果flag为flase就将其设置为true
    if (atomicBooleanFlag.compareAndSet(false, true)) {
      log.info("doSomething executed");
    }
  }
}


输出


20190217152835372.png

原子更新数组


通过原子的方式更新数组里的某个元素,Atomic包提供了以下3个类。

  • AtomicIntegerArray : 原子更新整型数组里的元素
  • AtomicLongArray : 原子更新长整型数组里的元素
  • AtomicReferenceArray : 原子更新引用类型数组里的元素

我们以AtomicIntegerArray为例来演示下用法


20190217115457828.png

常用方法


int addAndGet(int i,int delta):以原子方式将输入值与数组中索引i的元素相加

boolean compareAndSet(int i,int expect,int update):如果当前值等于预期值,则以原子方式将数组位置i的元素设置成update值


Demo

package com.artisan.example.atomic;
import java.util.concurrent.atomic.AtomicIntegerArray;
import lombok.extern.slf4j.Slf4j;
@Slf4j
public class AtomicIntegerArrayDemo {
  private static int[] array = new int[] { 11, 22 };
  private static AtomicIntegerArray atomicIntegerArray = new AtomicIntegerArray(array);
  public static void main(String[] args) {
    // 给array[0]的值增加33 ,然后返回增长后的值 44
    log.info("atomicIntegerArray addAndGet :{}", atomicIntegerArray.addAndGet(0, 33)); // 44
    // 输出 atomicIntegerArray中
    log.info("atomicIntegerArray get :{}", atomicIntegerArray.get(0)); // 44
    // 数组value通过构造方法传递进去,然后AtomicIntegerArray会将当前数组 复制一份,
    // 所以当AtomicIntegerArray对内部的数组元素进行修改时,不会影响传入的数组
    log.info("array[0]的值: {}", array[0]); // 11
    // 先get 然后再add ,返回add之前的值
    log.info("atomicIntegerArray getAndAdd :{}", atomicIntegerArray.getAndAdd(0, 33)); // 44
    log.info("atomicIntegerArray .get(0) :{}", atomicIntegerArray.get(0)); // 44+33
    log.info("array[0]的值: {}", array[0]); // 11
    // 先get ,然后再set,返回set之前的数据
    log.info("atomicIntegerArray getAndSet :{}", atomicIntegerArray.getAndSet(0, 33));// 77
    log.info("atomicIntegerArray get(0) :{}", atomicIntegerArray.get(0)); // 33
    log.info("array[0] :{}", array[0]); // 11 
  }
}

20190217130529295.png


数组value通过构造方法传递进去,然后AtomicIntegerArray会将当前数组复制一份,所以当AtomicIntegerArray对内部的数组元素进行修改时,不会影响传入的数组


原子更新引用类型


原子更新基本类型的AtomicInteger,只能更新一个变量,如果要原子更新多个变量,就需要使用这个原子更新引用类型提供的类.

Atomic包提供了以下3个类


AtomicReference:原子更新引用类型

AtomicReferenceFieldUpdater:原子更新引用类型里的字段

AtomicMarkableReference:原子更新带有标记位的引用类型。可以原子更新一个布尔类型的标记位和引用类型


以AtomicReference为例,来看下用法



20190217132527577.png

Demo

package com.artisan.example.atomic;
import java.util.concurrent.atomic.AtomicReference;
import lombok.extern.slf4j.Slf4j;
@Slf4j
public class AtomicReferenceDemo {
  private static AtomicReference<Artisan> atomicReferenceArtisan = new AtomicReference<Artisan>();
  public static void main(String[] args) {
    Artisan expectedArtisan = new Artisan();
    expectedArtisan.setName("小工匠");
    expectedArtisan.setAge(20);
    // 将expectedArtisan设置到atomicReferenceArtisan
    atomicReferenceArtisan.set(expectedArtisan);
    Artisan updateArtisan = new Artisan();
    updateArtisan.setName("小工匠Update");
    updateArtisan.setAge(99);
    // compareAndSet方法进行原子更新操作,如果是expectedArtisan,则更新为updateArtisan
    boolean mark2 = atomicReferenceArtisan.compareAndSet(new Artisan(), updateArtisan);
    log.info("更新是否成功:{}", mark2);// false
    boolean mark = atomicReferenceArtisan.compareAndSet(expectedArtisan, updateArtisan);
    log.info("更新是否成功:{}", mark); // true
    log.info("atomicReferenceArtisan name:{}", atomicReferenceArtisan.get().getName());
    log.info("atomicReferenceArtisan age:{}", atomicReferenceArtisan.get().getAge());
  }
}


结果


20190217132627786.png


原子更新字段类型


如果需原子地更新某个类里的某个字段时,就需要使用原子更新字段类.

Atomic包提供 了以下3个类进行原子字段更新


AtomicIntegerFieldUpdater:原子更新整型的字段的更新器。

AtomicLongFieldUpdater:原子更新长整型字段的更新器。

AtomicStampedReference:原子更新带有版本号的引用类型。该类将整数值与引用关

联起来,可用于原子的更新数据和数据的版本号,可以解决使用CAS进行原子更新时可能出现的ABA问题。


使用注意事项:


  1. 第一:因为原子更新字段类都是抽象类,每次使用的时候必须使用静态方法newUpdater()创建一个更新器,并且需要设置想要更新的类和属性
  2. 第二:更新类的字段(属性)必须使用public volatile修饰符


Demo

package com.artisan.example.atomic;
import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import lombok.extern.slf4j.Slf4j;
@Slf4j
public class AtomicIntegerFieldUpdaterDemo {
  // 创建原子更新器,并设置需要更新的对象类和对象的属性
  private static AtomicIntegerFieldUpdater<Artisan2> atomicIntegerFieldUpdaterArtisan = AtomicIntegerFieldUpdater
      .newUpdater(Artisan2.class, "age");
  public static void main(String[] args) {
    Artisan2 artisan = new Artisan2();
    artisan.setAge(20);
    log.info("目前atomicIntegerFieldUpdaterArtisan中age的值为:{}",atomicIntegerFieldUpdaterArtisan.get(artisan));
    if (atomicIntegerFieldUpdaterArtisan.compareAndSet(artisan, 20, 99)) {
      log.info("artisan的age属性的值期望为20,则将20更新为99,更新成功");
    }
    // 获取artisan更新后的age的值
    log.info("目前atomicIntegerFieldUpdaterArtisan中age的值为:{}",atomicIntegerFieldUpdaterArtisan.get(artisan));
    if (atomicIntegerFieldUpdaterArtisan.compareAndSet(artisan, 20, 99)) {
      log.info("artisan的age属性的值期望为20,则将20更新为99,更新成功");
    }else {
      log.info("artisan的age属性的值期望为20,则将20更新为99,更新失败. 目前age的值为:{}",atomicIntegerFieldUpdaterArtisan.get(artisan));
    }
  }
}


package com.artisan.example.atomic;
import lombok.Data;
@Data
public class Artisan2 {
  String name;
  public volatile int age;
}

结果:


2019021714282357.png


原子类线程安全的原理


请参考上篇博客,主要是UnSafe 以及compareAndSwapInt ( CAS). 【JDK8和8以前的实现方式略有不同

https://blog.csdn.net/yangshangwei/article/details/87489745#incrementAndGetUnSafe__compareAndSwapInt_CAS_54


代码


https://github.com/yangshangwei/ConcurrencyMaster

相关文章
|
1月前
|
安全 Java 程序员
面试直击:并发编程三要素+线程安全全攻略!
并发编程三要素为原子性、可见性和有序性,确保多线程操作的一致性和安全性。Java 中通过 `synchronized`、`Lock`、`volatile`、原子类和线程安全集合等机制保障线程安全。掌握这些概念和工具,能有效解决并发问题,编写高效稳定的多线程程序。
66 11
|
3月前
|
缓存 Java 开发者
Java多线程并发编程:同步机制与实践应用
本文深入探讨Java多线程中的同步机制,分析了多线程并发带来的数据不一致等问题,详细介绍了`synchronized`关键字、`ReentrantLock`显式锁及`ReentrantReadWriteLock`读写锁的应用,结合代码示例展示了如何有效解决竞态条件,提升程序性能与稳定性。
360 6
|
3月前
|
并行计算 数据处理 调度
Python中的并发编程:探索多线程与多进程的奥秘####
本文深入探讨了Python中并发编程的两种主要方式——多线程与多进程,通过对比分析它们的工作原理、适用场景及性能差异,揭示了在不同应用需求下如何合理选择并发模型。文章首先简述了并发编程的基本概念,随后详细阐述了Python中多线程与多进程的实现机制,包括GIL(全局解释器锁)对多线程的影响以及多进程的独立内存空间特性。最后,通过实例演示了如何在Python项目中有效利用多线程和多进程提升程序性能。 ####
|
3月前
|
设计模式 安全 Java
Java 多线程并发编程
Java多线程并发编程是指在Java程序中使用多个线程同时执行,以提高程序的运行效率和响应速度。通过合理管理和调度线程,可以充分利用多核处理器资源,实现高效的任务处理。本内容将介绍Java多线程的基础概念、实现方式及常见问题解决方法。
194 0
|
4月前
|
数据挖掘 程序员 调度
探索Python的并发编程:线程与进程的实战应用
【10月更文挑战第4天】 本文深入探讨了Python中实现并发编程的两种主要方式——线程和进程,通过对比分析它们的特点、适用场景以及在实际编程中的应用,为读者提供清晰的指导。同时,文章还介绍了一些高级并发模型如协程,并给出了性能优化的建议。
60 3
|
5月前
|
负载均衡 Java 调度
探索Python的并发编程:线程与进程的比较与应用
本文旨在深入探讨Python中的并发编程,重点比较线程与进程的异同、适用场景及实现方法。通过分析GIL对线程并发的影响,以及进程间通信的成本,我们将揭示何时选择线程或进程更为合理。同时,文章将提供实用的代码示例,帮助读者更好地理解并运用这些概念,以提升多任务处理的效率和性能。
90 3
|
5月前
|
并行计算 API 调度
探索Python中的并发编程:线程与进程的对比分析
【9月更文挑战第21天】本文深入探讨了Python中并发编程的核心概念,通过直观的代码示例和清晰的逻辑推理,引导读者理解线程与进程在解决并发问题时的不同应用场景。我们将从基础理论出发,逐步过渡到实际案例分析,旨在揭示Python并发模型的内在机制,并比较它们在执行效率、资源占用和适用场景方面的差异。文章不仅适合初学者构建并发编程的基础认识,同时也为有经验的开发者提供深度思考的视角。
|
4天前
|
Python
python3多线程中使用线程睡眠
本文详细介绍了Python3多线程编程中使用线程睡眠的基本方法和应用场景。通过 `time.sleep()`函数,可以使线程暂停执行一段指定的时间,从而控制线程的执行节奏。通过实际示例演示了如何在多线程中使用线程睡眠来实现计数器和下载器功能。希望本文能帮助您更好地理解和应用Python多线程编程,提高程序的并发能力和执行效率。
32 20
|
10天前
|
安全 Java C#
Unity多线程使用(线程池)
在C#中使用线程池需引用`System.Threading`。创建单个线程时,务必在Unity程序停止前关闭线程(如使用`Thread.Abort()`),否则可能导致崩溃。示例代码展示了如何创建和管理线程,确保在线程中执行任务并在主线程中处理结果。完整代码包括线程池队列、主线程检查及线程安全的操作队列管理,确保多线程操作的稳定性和安全性。
|
2月前
|
NoSQL Redis
单线程传奇Redis,为何引入多线程?
Redis 4.0 引入多线程支持,主要用于后台对象删除、处理阻塞命令和网络 I/O 等操作,以提高并发性和性能。尽管如此,Redis 仍保留单线程执行模型处理客户端请求,确保高效性和简单性。多线程仅用于优化后台任务,如异步删除过期对象和分担读写操作,从而提升整体性能。
79 1

热门文章

最新文章