Java线程安全中的原子性浅析
作者:绿仔牛奶_ 发布时间:2021-09-06 16:08:13
何为原子性
原子性:一条线程在执行一系列程序指令操作时,该线程不可中断。一旦出现中断,那么就可能会导致程序执行前后的结果不一致。与数据库中的原子性(事务管理体现)是相同的
概括:一段程序只能由一条线程去完整的执行,不能被多个线程干扰执行
以最经典的转账为例,甲向乙的账户转账500这个转账行为就包含了两个操作:分别是1. 甲的账户-500 2. 乙的账户 +500但如果此时不能保证原子性操作就可能会出现甲的账户减了500但是乙的账户没有加500的情况
首先我们先来区分哪些是原子操作哪些非原子操作:
int a = 1; // (1)
int b = a; // (2)
a += b; // (3)
(1)一个操作,就是将值“1” 赋给 变量a
(2)两个操作,首先获取a的值,然后将a的值赋给b
(3)四个操作,首先获取b的值,再获取a的值,再将a与b的值相加,再将相加后的值赋给a
所以只有(1)和(3)属于原子操作,(2)不构成原子操作
上述举例,我们清楚了原子操作就是一个不可分割的操作。
下面我们来看线程安全的原子性示例:
测试代码:
public class Demo{
public static void main(String[] args) {
Temp task = new Temp();
// 启动100条线程
for (int i = 1; i <= 100 ; i++) {
new Thread(task).start();
}
}
}
class Temp implements Runnable{
private int count = 0;
@Override
public void run() {
// 线程任务:将count
for (int i = 1; i <= 100; i++) {
count++;
System.out.println(Thread.currentThread().getName()+"::count====>>"+count);
}
}
}
上述代码实现将Count从0加到10000,每一条线程控制count加100,100条线程启动执行实现。但是在执行过程中会发现会出现几次无法达到10000的结果,产生的原因就是假设当某一条线程在执行count累加时执行到了count=97时(也就是该线程执行失败,并且提交了执行失败的结果)cpu被其他线程拿到,那么其他线程继续拿到count=97进行累加,这样就导致最后结果不准确这个时候线程就不是安全的,也就是说我们这段程序是不具备原子性的。
但是有时效果不是很明显,建议可以将线程数增加到500条;
那么原子性的问题如何解决呢?
解决方法
加锁–> 悲观锁(阻塞同步)
利用synchronized修饰的同步方法、同步代码块啥的,随便你怎么上锁都可以,本质上的解决机理就是保证线程任务同时只能被一条线程执行,在执行完毕之前其他线程无法拿到执行权。由此来保证线程的原子性
从时间维度上来讲,某一时刻只允许一条线程执行线程任务,其他线程就处于阻塞状态,这种利用阻塞其他线程的方式就称为阻塞同步也叫做互斥同步。大大降低了执行效率和性能
这种解决方式采用了悲观的并发策略,synchronized也被称为悲观锁,为什么说是悲观?因为程序在加锁之初就默认每一次线程操作共享资源时都会被其他线程干扰。即在不进行同步干预的情况下,程序默认每次线程操作共享资源都会存在其他线程的竞争继而导致程序执行出现问题。阻塞同步也就是做出了最坏的打算,故称为悲观锁
使用原子类( Atomic )–> 乐观锁(非阻塞同步)
为什么还要使用原子类?
because 利用synchronized加锁去解决原子性问题,性能太低了。如果我们的程序线程数量太大,那每次线程任务只能被单条线程执行,效率太低了
原子类是性能高效、线程安全。并且Java提供了比较全面的原子类供开发者使用,下面以AtomicInteger为例来说它的方法使用,多数原子类的方法都有些类似
// 导包
import java.util.concurrent.atomic.AtomicInteger;
AtomicInteger整型原子类
// 常用方法
public final int set(int newValue) //为当前对象赋值
public final int get() //获取当前值
public final int getAndSet(int newValue)//获取当前值然后重新赋值
public final int getAndIncrement()//先获取当前值然后自增
public final int getAndDecrement() //先获取当前值然后自减
public final int getAndAdd(int delta) //获取当前值然后加上delta
boolean compareAndSet(int expect, int update) //如果当前值等于预期值,则以原子方式将该值设置为输入值(update)
除了整型原子类之外还有如长整型原子类AtomicLong、布尔原子类AtomicBoolean、整型数组AtomicIntegerArray、长整型数组AtomicLongArray、引用数据类型数组AtomicReferenceArray等
CAS机制(Compare And Swap)
什么是CAS?
CAS( Compare And Swap )意为比较并交换,CAS的实现机制就是利用了非阻塞同步。
采用乐观的并发策略,当程序运行中,我们不再利用阻塞其他线程来保证当前线程正确执行的方式,而是作出最优情况的解决方案,故而也被称为乐观锁。
即每一次线程操作共享资源都会执行成功并提交正确的结果,但是在将最新的结果提交时,需要与当前存储的值进行比较就是进行一个新值与原值冲突检测,比较完之后如果发现最新结果与当前值一致则说明执行失败,反之则是执行成功然后替换到原值即可
我们依然用上述操作count作为示例,如下图所示
可以看出,不论任何一条线程正在操作count,都可以与其他线程进行竞争。非阻塞同步大大的节省了线程阻塞和唤醒的性能开销
下面谈一下CAS具体的实现机制(CAS算法)
CAS实现主要用到三个操作数,分别是 内存地址S、原值(预期值)A、新值B
当线程向主内存中提交一个共享变量的新值B时,首先会将原值A与S处存储的值进行比较,只有当两个值相同时(没有其他线程干扰),才能将新值B提交至主内存更新共享变量
CAS算法真正关注的是线程提交时的S处值与预期值是否相同,但仍然存在ABA漏洞,暂时不做深究
来源:https://blog.csdn.net/yuqu1028/article/details/128608067
猜你喜欢
- 有很多同学肯定想学习opencv相关的知识,但是有些情况下每建一次项目都要重新引入下各种文件是不是很苦恼,所以我也面临了这个问题,在网上看到
- 本文介绍SpringBoot如何使用Prometheus配合Grafana监控。1.关于PrometheusPrometheus是一个根据应
- 前言我们知道在Java中除了基础的数据类型以外,其它的都为引用类型。而Java根据其生命周期的长短将引用类型又分为强引用、软引用、弱引用、幻
- package com.letv.cloud.spider;import java.util.HashSet;import java.uti
- 1. strlen —— 求字符串长度1.1 strlen 的声明与用处strlen ,我们有一些英
- Java虚拟机(JVM)是可运行Java代码的假想计算机。只要根据JVM规格描述将解释器移植到特定的计算机上,就能保证经过编译的任何Java
- 本文为大家分享了如何使用eclipse创建java项目,供大家参考,具体内容如下首先,打开Eclipse,在工具栏依次点击【File】>
- 异常的英文单词是exception,字面翻译就是“意外、例外”的意思,也就是非正常情况。事实上,异常本质上是程序上的错误,包括程序逻辑错误和
- ApplicationContext简述ApplicationContext代表IOC容器,在SpringIOC容器中读取Bean配置创建B
- 本文实例讲述了java基于递归算法实现汉诺塔问题。分享给大家供大家参考,具体如下:package test;import java.util
- 详解java 中Spring jsonp 跨域请求的实例jsonp介绍  
- Java在1.5开始引入了注解,目前流行的框架都在用注解,可想而知注解的强大之处。以下通过自定义注解来深入了解java注解。一、创建自定义注
- 一、什么是SFTP?SFTP是一个安全文件传送协议,可以为传输文件提供一种安全的加密方法。SFTP 为 SSH的一部份,是一种传输文件到服务
- 一. * 搭建及配置1 . * 简介 * 是架设在局域网的一种特殊的远程仓库,目的是代理远程仓库及部署第三方构件。有了 * 之后,当 Maven
- Math.PI 记录的圆周率Math.E 记录e的常量Math中还有一些类似的常量,都是一些工程数学常用量。Math.ab
- 话不多说,请看代码:<!DOCTYPE html><html><head> <meta
- 概念在Java中,对象的生命周期包括以下几个阶段:创建阶段(Created)应用阶段(In Use)不可见阶段(Invisible)不可达阶
- 区块链是目前最热门的话题,广大读者都听说过比特币,或许还有智能合约,相信大家都非常想了解这一切是如何工作的。这篇文章就是帮助你使用 Java
- 接触FFmpeg有一段时间了,它是音视频开发的开源库,几乎其他所有播放器、直播平台都基于FFmpeg进行二次开发。本篇文章来总结下采用FFm
- 最近在做项目的时候,一直用一个叫做API的东西,controller注解我会写,这个东西我也会用,但是我确实不知道这个东西是个什么,有点神奇