当前位置：主页 > java教程 > Java线程原子性

Java线程安全中的原子性浅析

发布：2023-03-27 15:05:02 59

为网友们分享了相关的编程文章，网友傅琴轩根据主题投稿了本篇教程内容，涉及到Java线程原子性、Java线程安全原子性、Java线程原子性相关内容，已被542网友关注，下面的电子资料对本篇知识点有更加详尽的解释。

Java线程原子性

何为原子性

原子性：一条线程在执行一系列程序指令操作时，该线程不可中断。一旦出现中断，那么就可能会导致程序执行前后的结果不一致。与数据库中的原子性（事务管理体现）是相同的

概括：一段程序只能由一条线程去完整的执行，不能被多个线程干扰执行

以最经典的转账为例，甲向乙的账户转账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等