首页 > 其他分享 >多线程篇-线程安全-原子性、可见性、有序性解析

多线程篇-线程安全-原子性、可见性、有序性解析

时间:2023-05-11 18:56:09浏览次数:37  
标签:finish 变量 val no 线程 内存 有序性 多线程

在程序中使用多线程的目的是什么?

1、提高效率,增加任务的吞吐量2、提升CPU等资源的利用率,减少CPU的空转

多线程的应用在日常开发中很多,带来了很多的便利,让我们以前研究下在多线程场景中要注意问题吧,一般主要从这三个方面考虑

1、原子性2、可见性3、有序性

如果不能保证原子性、可见性和顺序性会有什么问题?这些问题怎么解决呢?让我们一起来看下

 

一、原子性

原子性的操作是不可被中断的一个或一系列操作。

个人理解,严格的原子性的操作,其他线程获取操作的变量时,只能获取操作前的变量值和操作后的变量值,不能获取到操作过程中的中间值,在操作过程中其他操作需要获取变量值,需要进入阻塞状态等待操作结束。

如果不能保证原子性会有什么问题呢

让我们一块看一个简单例子吧

首先写一个简单的线程,代码如下

public class ThreadDemo implements Runnable {
    int no = 0;
    @Override public void run() {
        no++;
        System.out.println(no);
    }
    public static void main(String[] args) {
        ThreadDemo demo = new ThreadDemo();
        for(int i=0;i<1000;i++){
            Thread task = new Thread(demo);
            task.start();
        }
    }
}

main函数中启动了1000个线程,每个线程都对no进行了一次+1操作,理想情况下no最后的结果应该是1000,可是我的运行最终结果只有996,执行了1000次+1操作,最后的结果为什么不是1000呢,这就要说到no++操作不是原子的问题了(no可见性的问题在下一个小结讨论)

先对no++这个操作分解,可以分为三步:取值,加一,赋值,这三个操作都是原子的,不过合在一起就不行了。两个线程A、B一起来操作no,no初始值是1,线程A读取no值是1,然后做no+1,这时线程B对 no取值还是1,然后A将2赋值给no,B操作no+1结果是2,也将2赋值给no。对1做了两次+1操作,最后结果是2。这个过程可以参考下图

所以,需要保证这种不可分割操作的原子性,那要怎么做才能保证原子性呢,有两种方式

1、加锁synchronized,保证同一时间只有一个线程操作变量,其他线程需等待操作结束才能使用临界资源

2、使用CAS操作,变量计算前保留一份旧值a,计算完成后结果值为b,把b刷到内存之前先比较a是否和内存中变量一致,如果一致,就把内存中的变量赋值为b,不一样,重新获取内存中变量值,重复一遍操作,一直到a和内存中一致,操作结束。

Lock和原子类(AtomicInteger等)是通过使用unsafe的compareAndSwap方法实现CAS操作保证原子性的。

 

二、可见性

线程变量的可见性问题,需要从操作系统的CPU、缓存、内存的矛盾开始说起。读写性能上 CPU>缓存>内存>I/O。CPU/缓存/内存的结构看下图。

CPU和内存之间隔着缓存和CPU寄存器。缓存还分为一级、二级、三级缓存。CPU的读写性能上要大于内存,为了提高效率会将数据先取到缓存中,CPU处理完数据后会先放到缓存中,然后同步到内存中。

如果不理解CPU缓存这部分内容的话,可以简单的认为每个线程都有自己的本地工作内存,变量会先缓存到本地工作内存中使用,修改后会先修改工作内存中的存储,然后在同步到主内存中。结构如下图

这种内存结构会引起什么问题呢,现在有一个变量var,线程A对var做了一次修改,刚放到缓存(工作内存)还未同步到内存时,另外一个线程B也来使用var,读取到的还是var未修改值。

共享的变量需要保证可见性,怎么保证共享变量的可见性呢

1、加锁(加锁是万能的操作)synchronized和Lock都可以保证

线程在加锁时,会清空工作内存中共享变量的值,共享变量使用是需要从主内存中重新获取。线程解锁是,会把共享变量重新刷新到主内存中。

2、使用volatile修饰共享变量,volatile修饰的共享变量在修改后会立即被更新到内存中,其他线程使用共享变量会去内存中读取

优先使用volatile来解决可见性问题,加锁需要消耗的资源太多。

 

三、有序性

为了优化程序性能,编译器、处理器和运行时会对代码指令进行重排,重排过程中会遵循as-if-serial语义,即不影响单线程的运行结果。

扩展一下 指令重排为什么会提高程序性能呢,CPU是多核处理的,为了保证处理器资源的充分利用,对代码指令进行乱序处理,即可以多个处理器并行处理指令,防止不相关的指令需要等待上一个指令结束才能开始。

代码执行顺序被重排会是什么效果呢,举个简单例子

inta =0;a=2;int b =1;intc= a+b;

这段代码中变量a和b 是相互不影响的,优化后可以是如下代码,只要保证执行结果不变,有依赖的变量c在变量a和b之后处理即可

intb =1; int a =0;a=2;intc= a+b;

在单线程中这样是没有问题的,如果是多线程呢,看下如下代码

public static void main(String[] args){
    Object val =null;
    boolean finish =false;
    Runnable task1 = new Runnable() {
        Object val;
        boolean finish;
        public void setVal(Object val,boolean finish) {
            this.val= val;
            this.finish = finish;
        }
        @Overridepublicvoid run() {
            if(this.finish) {
                System.out.println(this.val.toString());
            }
        }
    };
    Runnable task2 = new Runnable() {
        Object val;
        boolean finish;
        public void setVal(Object val,boolean finish) {
            this.val= val;
            this.finish = finish;
        }
        @Override public void run() {
            val = new Object();
            finish =true;
        }
    };
}

分别创建两个任务task1和task2,他们共享两个变量val和finish,按现在的顺序执行的话,task1不会出现val为null时被使用的情况。不过进行了指令重排之后呢,task2中val和finish操作顺序调整对单线程来说是没有任何影响的,所以task2的代码可能会变成

@Override public void run() {
    finish =true;
    val = new Object();
}

这样task1中,就会出现finish为true,val为null的情况了。

那么怎么保证多个线程中的代码顺序一致性呢

1、加锁(还是加锁)synchronized和Lock,保证同一时刻只有一个线程进行操作

2、使用volatile修饰变量,在JMM中volatile的读和写都会插入内存屏障来禁止处理器的重排

这样原子性、可见性、有序性就基本讲完了,其中有很多的知识点没有详细的说,例如:

CAS、volatile、synchronized、lock等等,这些会在后边的文章中慢慢研究。

注:如果弄不清楚原子性和可见性的区别,只要记住下边两点内容

1、原子性针对完整的操作过程,其他操作只能获取操作前或操作后的变量数据

2、可见性主要是变量修改,变量修改后,马上刷新到内存中,而其他线程能感知到变量的修改

 

标签:finish,变量,val,no,线程,内存,有序性,多线程
From: https://www.cnblogs.com/maji233/p/17391926.html

相关文章

  • 线程安全的概念
    做软件开发有几年了,发现在软件开发中出现的问题哪种的比较多呢,不是测试出来的页面逻辑、页面效果、数据处理问题,而是被大多数人忽略的线程安全的问题。线程安全我认为才是软件开发中的主要问题,但是因为其隐晦性和工作中盲目追赶项目进度造成堆积代码,以及基本功的不扎实,导致软件时......
  • 多线程实现高并发服务器
    /*多线程实现并发服务器主线程负责接收子线程负责处理*/#include<stdio.h>#include<arpa/inet.h>#include<string.h>#include<stdlib.h>#include<sys/types.h>#include<unistd.h>#include<wait.h>#include<si......
  • java线程池和多线程的使用详解
    Java多线程和线程池使用java多线程实现的几种方法1.继承Thread类继承Thread类,重写run方法,创建线程类对象调用start方法启动线程。publicclassThreadDemo{/***继承Thread类创建线程*/publicstaticclassMyThreadextendsThread{publ......
  • JS单线程的理解
    一、首先需要区分几个概念:1. 进程和线程的概念:进程:指在系统中运行的一个应用程序,目的就是担当分配系统资源(CPU时间、内存等)的基本单位线程:系统分配处理器时间资源的基本单元,建立在进程的基础上,一个进程至少要有一个线程。2. 浏览器是多进程,多线程的,而JS是单线程的:......
  • python 多线程与队列
    多线程是指在一个程序中同时运行多个线程,每个线程都可以独立地执行特定的任务。在Python中,可以使用内置的threading模块来创建和管理线程。使用多线程的主要优点是能够提高程序的性能和响应速度,特别是在处理I/O操作时。通过将耗时的任务放入后台线程中,主线程可以继续执行其他任务......
  • QT中线程睡眠对数据IO的影响——串口bug记录
    这两天用QT做一个上位机,涉及到有一个数据发送完后需要用到延时,我一开始使用了线程休眠的方式进行延时://发送读取指令if(serialport->write(data)==-1){qDebug()<<"发送失败!";}QThread::msleep(1000);serialport->clear();然后我发现data并没有被发......
  • 两个线程交替打印100以内的数字
    共享内存classtest{privatestaticintcount=0;//共享的计数器publicstaticvoidmain(String[]args){Threadt1=newThread(newPrinter(0));Threadt2=newThread(newPrinter(1));t1.start();t2.start();......
  • Java程序设计-实验五 Java多线程程序设计
    目的1.掌握Runnable接口实现多线程的方法2.掌握Thread类实现多线程的用法3.掌握Java语言中多线程编程的基本方法1.线程接力(45分)要求:编写一个应用程序,除了主线程外,还有三个线程:first、second和third。first负责模拟一个红色的按钮从坐标(10,60)运动到(100,60);second负......
  • JAVA的线程池随笔
    线程池基本概念概念:线程池主要是控制运行线程的数量,将待处理任务放到等待队列,然后创建线程执行这些任务。如果超过了最大线程数,则等待。优点:线程复用:不用一直new新线程,重复利用已经创建的线程来降低线程的创建和销毁开销,节省系统资源。提高响应速度:当任务达到时,不用创建新的......
  • Python多线程(multithreading)
    1.threading模块Python3线程中常用的两个模块为:_thread,threading(推荐使用).thread模块已被废弃,为了兼容性,Python3将thread重命名为_thread,即通过标准库_thread和threading提供对线程的支持。_thread提供了低级别的、原始的线程以及一个简单的锁,它相比于threading模块的功能还......