并发编程之多线程线程安全(下)-程序员宅基地

技术标签: java  

1、什么是 Volatile?

volatile 是一个类型修饰符,具有可见性,也就是说一旦某个线程修改了该被 volatile 修饰的变量,它会保证修改的值会立即被更新到主存,当有其他线程需要读取时,可以立即获取修改之后的值。

在 java 中为了加快程序的运行效率,对一些变量的操作通常是在该线程的寄存器或是 CPU 缓存上进行的,之后才会同步到主存中,而加了 volatile 修饰符的变量则是直接读写主存。

[可以搜索了解一下 java 中的内存模型]

看下面一段代码:

class ThreadVolatileDemo extends Thread {
     

    public boolean flag = true;

    @Override
    public void run() {
        System.out.println("开始执行子线程....");
        while (flag) {
        }
        System.out.println("线程停止");
    }

    public void setRuning(boolean flag) {
        this.flag = flag;
    }
}

public class ThreadVolatile {
    public static void main(String[] args) throws InterruptedException {
        ThreadVolatileDemo threadVolatileDemo = new ThreadVolatileDemo();
        threadVolatileDemo.start();
        Thread.sleep(3000);
        threadVolatileDemo.setRuning(false);
        System.out.println("flag 已经设置成false");
        Thread.sleep(1000);
        System.out.println(threadVolatileDemo.flag);
    }
}

运行结果:

开始执行子线程....
flag 已经设置成false
false

已经将结果设置为 fasle 为什么?还一直在运行呢。

原因:线程之间是不可见的,读取的是副本,没有及时读取到主内存结果。

解决办法使用 volatile 关键字将解决线程之间可见性, 强制线程每次读取该值的时候都去“主内存”中取值。

2、Volatile 与 Synchronize 的区别?
  1. volatile 虽然具有可见性但是并不能保证原子性。
  2. 性能方面,synchronized 关键字是防止多个线程同时执行一段代码,就会影响程序执行效率,而 volatile 关键字在某些情况下性能要优于synchronized。但是要注意 volatile 关键字是无法替代 synchronized 关键字的,因为 volatile 关键字无法保证操作的原子性。

上篇以及本篇多次提及原子性,借此重新了解一下多线程中的三大特性。

原子性、可见性、有序性。

2.1、什么是原子性?

如果有了解过事务的小伙伴,这一块就比较好理解了,所谓的原子性即一个或多个操作,要么全部执行完成,要么就都不执行,如果只执行了一部分,对不起,你得撤销已经完成的操作。

举个例子:

账户 A 向账户 B 转账 1000 元,那么必然包括 2 个操作:从账户 A 减去 1000,向账户 B 加上 1000,这两个操作必须要具备原子性才能保证不出现一些意外的问题发生。

总结:所谓的原子性其实就是保证数据一致、线程安全的一部分。

2.2、什么是可见性?

当多个线程访问同一个变量时,一个线程修改了这个变量的值,其他线程就能够立即看到修改的值。

若两个线程在不同的 cpu,有个变量 i ,线程 1 改变了 i 的值还没有刷新到主存,线程 2 又使用了 i,那么这个 i 值肯定还是之前的,线程 1 对变量的修改,线程2 没有看到,这就是可见性问题了。

2.3、什么是有序性?

即程序执行时按照代码书写的先后顺序执行。在Java内存模型中,允许编译器和处理器对指令进行重排序,但是重排序过程不会影响到单线程程序的执行,却会影响到多线程并发执行的正确性。(本文不对指令重排作介绍,但不代表它不重要,它是理解 java 并发原理时非常重要的一个概念)。

重排序文章留空,后面补充。

3、多线程之间的通讯

什么是多线程之间的通讯?

多线程之间通讯,其实就是多个线程在操作同一个资源,但是操作的动作不同。画图演示:

多线程之间的通讯需求:

第一个线程写入(input)用户,另一个线程读取(out)用户,实现读一个写一个操作。

代码实现:

共享资源实习类 Res

class Res2{
     
    public String userName;
    public String userSex;
}

class InputThread extends Thread{

    private Res2 mRes;

    public InputThread(Res2 mRes){
        this.mRes = mRes;
    }

    @Override
    public void run() {
        int count = 0;
        while (true) {
            synchronized (mRes){
                if (count == 0) {
                    mRes.userName = "余胜军";
                    mRes.userSex = "男";
                } else {
                    mRes.userName = "小紅";
                    mRes.userSex = "女";
                }
                count = (count + 1) % 2;
            }
        }
    }
}

class OutThread extends Thread{

    private Res2 mRes;

    public OutThread(Res2 mRes){
        this.mRes = mRes;
    }

    @Override
    public void run() {
        while (true){
            System.out.println(mRes.userName + "--" + mRes.userSex);
        }
    }
}

public class Demo9 {

    public static void main(String[] args){

        Res2 res = new Res2();
        InputThread intThrad = new InputThread(res);
        OutThread outThread = new OutThread(res);
        intThrad.start();
        outThread.start();

    }

}

打印结果:

...
余胜军--男
小紅--女
小紅--女
余胜军--男
小紅--女

在代码中我们用到了 synchronized 关键字解决线程线程安全问题,所以实现了正确打印,如果不使用 synchronized 的话,可能会出现如下打印的脏数据:

余胜军--女
小紅--女
小紅--男
余胜军--男
小紅--女
wait()、 notify() 方法。

关于该方法的介绍:

  1. 因为涉及到对象锁,他们必须都放在 synchronized 中来使用。
  2. wait 必须暂停当前正在执行的线程,并释放资源锁,让其他线程可以有机会运行。
  3. notify/notifyall:唤醒锁池中的线程,使之运行。

了解了 wait、notify 方法后,我们来改造一下上边的代码:

class Res2{
     
    public String userName;
    public String userSex;
    public boolean flag = false;/*线程通讯标识*/
}

class InputThread extends Thread{

    private Res2 mRes;

    public InputThread(Res2 mRes){
        this.mRes = mRes;
    }

    @Override
    public void run() {
        int count = 0;
        while (true) {
            synchronized (mRes){
               if(mRes.flag){
                   try {
                       mRes.wait();
                   }catch (Exception e){

                   }
               }
               if (count == 0) {
                    mRes.userName = "余胜军";
                    mRes.userSex = "男";
                } else {
                    mRes.userName = "小紅";
                    mRes.userSex = "女";
                }
                count = (count + 1) % 2;

                mRes.flag = true;
                mRes.notify();
            }
        }
    }
}

class OutThread extends Thread{

    private Res2 mRes;

    public OutThread(Res2 mRes){
        this.mRes = mRes;
    }

    @Override
    public void run() {
        while (true){

            synchronized (mRes){
                if(!mRes.flag){

                    try {
                        mRes.wait();
                    } catch (Exception e) {}
                }

                System.out.println(mRes.userName + "--" + mRes.userSex);

                mRes.flag = false;
                mRes.notify();
            }

        }
    }
}

public class Demo9 {

    public static void main(String[] args){

        Res2 res = new Res2();
        InputThread intThrad = new InputThread(res);
        OutThread outThread = new OutThread(res);
        intThrad.start();
        outThread.start();

    }

}
wait() 与 sleep() 区别?

sleep() 方法时属于 Thread 类的,而 wait() 方法是属于 Object 类的。

sleep() 方法导致了程序暂停执行指定的时间,让出 cpu 给其他线程,但是它的监控状态依然保持着,当指定的时间到了又会自动恢复运行状态。

在调用 sleep() 方法的过程中,线程不会释放对象锁。

而当调用 wait() 方法的时候,线程会放弃对象锁,进入等待此对象的等待锁定池,只有针对此对象调用 notify() 方法后本线程才进入对象锁池准备,获取对象锁进入运行状态。

Lock锁(显示锁)

lock接口提供了与 synchronized 关键字类似的同步功能,但需要在使用时需要手动获取锁和释放锁。

代码示例:

Lock lock  = new ReentrantLock();
lock.lock();
try{
    /*可能会出现线程安全的操作*/
}finally{
    /*一定在finally中释放锁*/
    /*也不能把获取锁在try中进行,因为有可能在获取锁的时候抛出异常*/
    lock.ublock();
}
Condition用法—Lock中的wait()、notify()

Condition 的功能类似于在传统的线程技术中的 Object.wait() 和 Object.notify() 的功能。

代码:

Condition condition = lock.newCondition();

res. condition.await();  类似wait

res. Condition. Signal() 类似notify
synchronized 与 lock 的区别

synchronized 重量级,lock 轻量级锁,synchronized 不可控制,lock 可控制。

lock 相对 synchronized 比较灵活。

我创建了一个java相关的公众号,用来记录自己的学习之路,感兴趣的小伙伴可以关注一下微信公众号哈:niceyoo

转载于:https://www.cnblogs.com/niceyoo/p/11173243.html

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/weixin_30673715/article/details/101666748

智能推荐

灰色预测原理及实例(附代码)_灰色模型预测实例-程序员宅基地

文章浏览阅读1.3w次,点赞52次,收藏312次。Matlab灰色预测GM(1,1)模型,实例讲解附例题及代码。_灰色模型预测实例

模拟alt+tab切换_如何“ Alt + Tab”在Mac上切换Windows-程序员宅基地

文章浏览阅读1.6k次。模拟alt+tab切换If you’re a Mac user familiar with quickly switching between apps on Windows using Alt+Tab, you might be delighted to learn that there is a built-in way to do something very similar on a Ma..._mac怎么设置alt+tab切换

使用windows命令行能做哪些趣事_windows终端指令能干什么-程序员宅基地

文章浏览阅读1.6k次,点赞2次,收藏15次。使用windows命令行能做哪些趣事今天我们一起来盘点一下利用windows的命令行通过一行代码可以做哪些有趣的事吧!首先你要会启动命令行,首先通过win+R呼出运行工具,在运行工具中输入CMD就可以打开你的windows命令行工具了。通过windows自带的命令这种方式不需要你安装任何东西就可以运行命令ipconfigipconfig可以帮助你查询你本机的IP地址。..._windows终端指令能干什么

虚发下自己的心情-程序员宅基地

文章浏览阅读203次。自动变速器的挡位 一般来说,自动变速器的挡位分为P、R、N、D、2、1或L等。P(Parking):用作停车之用,它是利用机械装置去锁紧汽车的 转动部分,使汽车不能移动。当汽车需要在一固定位置上停留一段较长时间,或在停靠之后离开车辆前,应该拉好手制动及将拨杆推进“P”的位置上。要注意的是:车辆一定要在完全停止时才可使用P挡,要不然自动变速器的机械部分会受到损坏。另外,自动变速轿车上装置空挡_虚发

dbca.java:184_oracle em不能启动或者配置的解决方法-程序员宅基地

文章浏览阅读203次。很少使用oracle的em,最近突然想感受一下,发现原来配置的好好的em,突然无法启动了,重新配置也不行。报错内容如下:2011-03-16 13:50:28 Thread-69749664 ERROR ssl: nmehlenv_openWallet failed2011-03-16 13:50:28 Thread-69749664 ERROR http: 16: Error initializ..._./emctl status agent

【GIT工作记录二】sourceTree提交代码密钥验证失败(1),2024年最新面试Web前端-程序员宅基地

文章浏览阅读378次,点赞3次,收藏5次。面试题千万不要死记,一定要自己理解,用自己的方式表达出来,在这里预祝各位成功拿下自己心仪的offer。网上学习资料一大堆,但如果学到的知识不成体系,遇到问题时只是浅尝辄止,不再深入研究,那么很难做到真正的技术提升。需要这份系统化的资料的朋友,可以添加V获取:vip1024c (备注前端)一个人可以走的很快,但一群人才能走的更远!不论你是正从事IT行业的老鸟或是对IT行业感兴趣的新人,都欢迎加入我们的的圈子(技术交流、学习资源、职场吐槽、大厂内推、面试辅导),让我们一起学习成长!,但一群人才能走的更远。

随便推点

HTMLElement对象_htmlinputelement-程序员宅基地

文章浏览阅读1.2k次。HTMLElement对象任何HTML元素都继承于HTMLElement对象,一些元素直接实现这个接口,而另一些元素通过多层继承来实现它。属性从其父元素Element继承属性,并从DocumentAndElementEventHandlers、ElementCSSInlineStyle、GlobalEventHandlers、HTMLOrForeignElement和TouchEventHandlers实现这些属性。HTMLElement.accessKey: 获取/设置元素访问的快捷键。HTM_htmlinputelement

三国志战略版:S9血刃开荒实录二_开六升七_三国志战略版s9开荒-程序员宅基地

文章浏览阅读224次。一、前言血刃开荒故事会,第二集,开荒第二天。经过昨天一天的耕耘,血刃开荒已成为可行方案。比较尴尬的是,熬夜打五的代价就是直接睡到新手期结束才上线233。体力也浪费了不少,虽然说我开荒比较佛系,但这也太那个了吧,所以咱们先赶紧打几个5开6再说吧。二、开六级地打了几个五之后,周围的五级基本上已经被瓜分干净了,咱们直接8000兵试试最近的一个6级石头。咱们进度落后,体力浪费,先从屯田6级石头上面找补找补吧。第一场效果非常不错,马超输出爆表,不过遗憾的是打完之后,我们C位马超的血量只有110_三国志战略版s9开荒

FFmpeg从入门到精通读书笔记(1)-程序员宅基地

文章浏览阅读540次。笔者才开始学习音视频开发,FFmpeg从入门到精通读书笔记系列主要是基于阅读刘歧、赵文杰编著的《FFmpeg从入门到精通》以及雷霄骅博士博客总结写的入门心得体会。官方文档资料FFmpeg官方文档:https://ffmpeg.org/documentation.htmlFFmpeg官方wiki:http://trac.ffmpeg.org/wiki中文经典资料雷霄骅博士csdn链..._ffmpeg从入门到精通

易语言查找过滤相同重复文本源码_易语言 模块 文本去重复-程序员宅基地

文章浏览阅读4.3k次。我们在把一些文本加入数组或者数据库时,不想加入重复相同的文本,那么我们可以封装一个子程序来过滤一下文本。.版本 2.子程序 查找相同文本.参数 文本数组, 文本型, 数组.参数 输出文本, 文本型, 数组.局部变量 文本数量, 整数型.局部变量 加入文本数量, 整数型.局部变量 是否存在, 逻辑型.计次循环首 (取数组成员数 (文本数组), 文本数量) .计次循环首 (取数组成员数 (输出文本), 加入文本数量) .如果真 (输出文本 [加入文本数量] =.._易语言 模块 文本去重复

【文件包含漏洞-02】文件包含漏洞原理、简单测试实例以及空字符绕过实例_cve-2006-7243-程序员宅基地

文章浏览阅读2.7k次,点赞5次,收藏30次。概述:文件包含漏洞:即file inclusion,意思是文件包含,是指当服务器开启allow_url_include选项时,就可以通过PHP的某些特性函数(include(),require()和include_once(),requir_once())利用URL去动态包含文件,此时如果没有对文件来源进行严格审查,就会导致任意文件读取或者任意命令执行。定义:随着网站业务的需求,程序开发人员一般希望代码更灵活,所以将被包含的文件设置为变量,用来进行动态调用,但是正是这种灵活性通过动态变量的方式引入需要包含的_cve-2006-7243

python小程序代码_python的多线程实现代码(模拟银行服务操作流程)-程序员宅基地

文章浏览阅读87次。文章内容主要介绍了python模拟银行服务多线程实现代码,非常不错,具有一定的参考借鉴价值!!!1.模拟银行服务完成程序代码目前,在以银行营业大厅为代表的窗口行业中大量使用排队(叫号)系统,该系统完全模拟了人群排队全过程,通过取票进队、排队等待、叫号服务等功能,代替了人们站队的辛苦。排队叫号软件的具体操作流程为:1.1 顾客取服务序号当顾客抵达服务大厅时,前往放置在入口处旁的取号机,并按一下其上的..._下列程序是模拟银行短信提醒的程序,pythob