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

技术标签: 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

智能推荐

Vue.js+Element:clipboard.js实现点击按钮复制内容到剪切板_vue 前端剪切板赋值-程序员宅基地

文章浏览阅读2.8k次。需求点击某个按钮,将设置的目标内容(例如地址)复制到剪切板引入clipboardjs官网传送门npm引入:npm install clipboard --save使用<template> <div class="drawer"> <el-switch v-model="isopen" /> <el-input placeho..._vue 前端剪切板赋值

if循环中悬空else问题-程序员宅基地

文章浏览阅读373次,点赞5次,收藏6次。之前学习Java时并没有注意到这个小细节的问题,不过最近新学C语言的过程中,突然发现居然还有一个这么小的语法细节知识,这也侧面展现了代码规范的重要性。

解决jaspersoft+ireport导出pdf空白_jasperfillmanager生产空白的pdf-程序员宅基地

文章浏览阅读2.7k次。使用ireport导出dpf显示空白解决步骤:1.【工具】-【选项】-【classpath】中添加iTextAsian.jar这个jar包不用自己下载,ireport自带的有,位置在D:\iReport-5.6.0\ireport\modules\ext下2.在报表工具【属性】-【text properties】中设置以下属性PDF font name: STSong-LightPDF Encoding: UniGB-UCS2-H(Chinese Siplified)PDF Em_jasperfillmanager生产空白的pdf

el-tooltip宽度超过父容器的宽度,导致提示框不跟随文字内容_react antd tooltip内容过多时,超出容器大小-程序员宅基地

文章浏览阅读206次。实现方式为: 给 tooltip一个display属性,除inline以外的任意值。_react antd tooltip内容过多时,超出容器大小

java es 搜索_使用elasticsearch从多个列表中搜索-程序员宅基地

文章浏览阅读1.3k次。我们有以下设置(简化/更改):MongoDB集合: ArticlesRedis列表: Today Yesterday This Week This Month我们经常收到新文章,并将它们放入适当的列表中(新文章进入'今天''本周'和'本月'[redis列表包含mongodb集合的id]) .这些列表可以包含很多项目(“本月”达到数百万) . 这些列表经常更改,文章消失并重新出现(业务逻辑) .这些..._elasticsearch search value in list

反激开关电源变压器设计实例讲解(定明芳)_反激变压器设计实例-程序员宅基地

文章浏览阅读2.8w次,点赞55次,收藏543次。内容来自《反激变压器的设计》(定明芳主讲)。定名芳老师主要讲了10步,最后应该还有一步,线径的选择已经绕制方式。这里进行了记录整理,把一些公式来源进行了推导。所有的设计都是基于理论计算。1.确定电源规格2.确定工作频率和最大占空比3.计算匝比(利用伏秒平衡原则)此处插入解释一下伏秒平衡,根源是磁通量平衡。该原则可以用来检查MOS管耐压是否够。4.计算初级线圈峰值电流基于CCM模式计算的。ip1是开关管要关闭时的峰值电流,ip2是开关管开始导通时的起始电流。因为时CCM模式,所以,ip_反激变压器设计实例

随便推点

机器学习&人工智能:大牛带你回顾2016,展望2017-程序员宅基地

文章浏览阅读206次。雷锋网按:2016即将过去,针对机器学习和人工智能领域在2016年取得的重大进展,以及2017年可能出现的新趋势,外媒KDnuggets咨询了12位业内顶级专家,汇集了他们的观点并整理成文,其中AlphaGo战胜李世石成为今年的标志性事件。雷锋网对全文进行了编译,未经许可,不得转载。1. Yaser Abu-Mostafa,加州理工学院顾问2016..._机器学习公平性展望

html5图片无限循环播放,原生js实现无限循环轮播图效果-程序员宅基地

文章浏览阅读3.6k次。知识要点1.实现无限循环的原理:以偏移的距离来判断是否跳回第一张和最后一张也可以利用循环判断图片的当前索引值var newLeft=parseInt(list.style.left)+offset;//当前的偏移量+下一次的偏移量=新的偏移量list.style.left=newLeft+"px";//当前的偏移值=新的偏移值//以偏移的距离来判断是否跳回第一张和最后一张if(newLeft>..._html5图片循环滚动

win10更新KB5034441版本,报错0x80070643_kb5034441更新失败-程序员宅基地

文章浏览阅读567次,点赞23次,收藏20次。当我学到一定基础,有自己的理解能力的时候,会去阅读一些前辈整理的书籍或者手写的笔记资料,这些笔记详细记载了他们对一些技术点的理解,这些理解是比较独到,可以学到不一样的思路。网安所有方向的技术点做的整理,形成各个领域的知识点汇总,它的用处就在于,你可以按照上面的知识点去找对应的学习资源,保证自己学得较为全面。观看零基础学习视频,看视频学习是最快捷也是最有效果的方式,跟着视频中老师的思路,从基础到深入,还是很容易入门的。,一般来说恢复分区的前一个分区是系统分区,也即。我这里有星号(*),是GPT类型的。

高可用与负载均衡入门与实战(五)——配置nginx反向代理和负载均衡_5)配置容器nginx1的web服务,编辑首页内容为“nginx1”,在宿主机访问-程序员宅基地

文章浏览阅读758次。任务一、配置nginx反向代理,使用nginx1、APP1、APP2三个容器步骤1:使用php-apache镜像启动APP1和APP2两个容器1)创建docker网络docker network create --subnet=172.18.0.0/16 cluster2)查看宿主机上的docker网络类型种类docker network ls3)启动容器APP1,设定地址为17..._5)配置容器nginx1的web服务,编辑首页内容为“nginx1”,在宿主机访问

线程池参数——workQueue用法_线程池参数workqueue-程序员宅基地

文章浏览阅读1.5k次。线程池参数的 workQueue 决定了缓存任务的排队策略,对于不同的业务场景,我们可以使用不同的排队策略。我们只需要实现BlockingQueue 这个接口即可。介绍一下常用的有三种workQueue1. SynchronousQueue(阻塞队列)SynchronousQueue没有容量,是无缓冲等待队列,是一个不存储元素的阻塞队列,会直接将任务交给消费者(即丢给空闲的线程去执行),必须等队列中的添加元素被消费后才能继续添加新的元素,否则会走拒绝策略,所以使用SynchronousQueu_线程池参数workqueue

Golang Gin 路由组 RouterGroup 路由分类处理请求_go gin 路由分组-程序员宅基地

文章浏览阅读1.1k次。在前面已经学习了gin框架如何处理请求,解析请求,返回数据。在实际的项目当中,项目往往是以模块化来进行划分和开发的,所谓的模块化就是按照功能来划分,比如会有产品模块,会有用户模块,会将用户相关的进行统一的开发,放到用户模块当中,和产品相关的放在产品相关的模块当中,这样即方便开发者进行统一的开发也方便在系统的维护过程当中方便维护。_go gin 路由分组