【JavaEE】多线程(三)线程的状态

news2024/11/18 21:28:07

✨哈喽,进来的小伙伴们,你们好耶!✨

🛰️🛰️系列专栏:【JavaEE】

✈️✈️本篇内容:线程的状态,线程安全问题!

🚀🚀代码存放仓库gitee:JavaEE初阶代码存放!

⛵⛵作者简介:一名双非本科大三在读的科班Java编程小白,道阻且长,星夜启程!

 接着上篇博客,我们已经学习了Thread类的基本用法,了解到创建线程,中断线程,等待线程,休眠线程是如何操作的,那么今天呢,我们接着往下学习。

我们知道,在之前博客已经介绍到进程有它的状态,比如就绪和阻塞,这里的状态决定了系统按照啥样的方式来调度这个进程。但是只针对一个进程里面只有一个线程的情况,那么更多的情况是一个进程中是存在多个线程的,所谓的状态其实是绑定在线程上的

目录

1、线程的状态

一、NEW

二、 TERMINATED

 三、RUNNABLE

四、TIMED_WAITING

五、 BLOCKED

六、WAITING

 2、线程安全问题

1、线程不安全的原因

2、一个线程不安全的实例

3、加锁操作

4、产生线程不安全的原因


1、线程的状态

一、NEW

new表示安排了工作还未开始行动。

看代码:while()循环里面啥也不用给,我们直接通过t.getState()这个方法获取指定线程的状态。

public class demo14 {
    public static void main(String[] args) throws InterruptedException {
        Thread t = new Thread(() -> {
            while (true) {

            }
        });
        System.out.println(t.getState());//通过这个方法获取指定线程的状态
        t.start();
    }
}

二、 TERMINATED

TERMINATED:表示工作完成了。

代码:这里我们直接去掉while()循环,啥也不用干,那肯定代码是执行完了,先调用start方法,然后获取我们的线程状态。

public class demo14 {
    public static void main(String[] args) throws InterruptedException {
        Thread t = new Thread(() -> {
            
        });
        t.start();
        Thread.sleep(1000);
        System.out.println(t.getState());
    }
}

 三、RUNNABLE

RUNNABLE:表示就绪状态。处于这个状态的线程,就是在就绪队列中,随叫随到,随时可以到CPU上执行。

代码:直接给一个空的while循环,不用加sleep等操作,方便我们观察代码的就绪状态。

public class demo14 {
    public static void main(String[] args) throws InterruptedException {
        Thread t = new Thread(() -> {
            while (true) {

            }
        });
        t.start();
        Thread.sleep(1000);
        System.out.println(t.getState());
    }
}

四、TIMED_WAITING

即代码中调用了sleep就会进入到TIMED_WAITING,意思就是当前线程在一定时间内是阻塞状态。

public class demo14 {
    public static void main(String[] args) throws InterruptedException {
        Thread t = new Thread(() -> {
            while (true) {
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        });
        t.start();
        Thread.sleep(1000);
        System.out.println(t.getState());
    }
}

五、 BLOCKED

表示排队等待其他事情。详情参考本文下面的3、加锁操作。

六、WAITING

也表示排队等待其他事情。

OK,到这里就可以总结出线程状态转换的简易图。

 2、线程安全问题

谈到线程安全,那么这里是很重要的一个板块,在面试中如果遇到多线程的问题,基本都会涉及到线程安全问题,同时也是一个难点,希望大家认真阅读。

1、线程不安全的原因

操作系统调度线程的时候是随机的,线程之间是抢占式执行,正因为这种特性很可能会导致程序出现一些bug。

2、一个线程不安全的实例

这里我们使用两个线程,对同一个整型变量各自-自增5w次,看最终的结果。

class Counter{
    public int count = 0;
    public void increase(){
        count++;
    }

public class demo15 {
    private static  Counter counter = new Counter();
    public static void main(String[] args) throws InterruptedException {
        Thread t1 = new Thread(() ->{
            for (int i = 0; i < 50000; i++) {
                counter.increase();
            }
        });
        Thread t2 = new Thread(()->{
            for (int i = 0; i < 50000; i++) {
                counter.increase();
            }
        });
        t1.start();
        t2.start();

        t1.join();
        t2.join();
        //必须要在t1,t2都执行完了之后,再打印count
        //否则,t1,t2,main都是并发执行的关系,导致t1,t2还没执行完,就先执行了下面的打印操作
        //在main中打印两个线程执行自增完成之后,得到的count结果
        System.out.println(counter.count);
    }
}

注意这里我们需要等待线程t1,t2都结束之后再打印结果,因为main线程和t1,t2线程是并发执行的关系,所以使用到了join函数。

运行结果:

 我们发现结果并不是10w,而是一个介于5w - 10w之间的数字,那么为什么会这样呢?

要想知道其中原因,我们就要来了解一个count++到低是如何实现的。

站在CPU的角度:count++实际上是三个CPU指令。

1、把内存中的count的值,加载到CPU寄存器中。(load)

2、把寄存器中的值+1。(add)

3、把寄存器的值写回到内存的count中。(save)

 由于线程调度是抢占式执行的,并且这个count++操作是分为3步来完成的,那么t1,t2同时执行这三个操作的时候,顺序上是有很多种可能的,这就可能导致我们最终的结果达不到10w。

一次异常演示:

结果为什么在5w - 10w之间?

 这5w并发相加中,有时候可能是串行的(+2),有时候可能是交错的,串行与交错多少次咋们不知道,这都是随机的,极端情况下,所有操作都是串行的,结果就是10w,所有操作都是交错的,结果就是5w,不过都是小概率事件。

3、加锁操作

那么如何解决上述线程不安全问题呢?

答案:加锁!

这里举个例子:比如李华准备去ATM机里面取钱,那么ATM机器一般是在一个小房间里面,当李华走进去的时候他就可以给这个房间的门上锁,这样赵四,王五等等想取钱的话只能等李华取完(这个等待操作就是阻塞),李华取完钱后便可以给这个房间解锁,下一个人才能进去取钱。

如何加锁?

那么java中加锁的方式有很多种,最常使用的是 synchronized 关键字。我们可以给上述代码重大的自增函数increase()前面加上synchronized 关键字就是加锁成功了。

    public int count = 0;
    synchronized public void increase(){
        count++;
    }

我们在看运行结果,这下便是10w,符合我们的预期。

那么给方法加上 synchronized 关键字之后,此时进入方法就会自动加锁,离开方法就会自动锁,当一个线程加锁成功的时候,其他线程尝试加锁就会触发阻塞等待。这个时候线程的状态就称为BLOCKED。

4、产生线程不安全的原因

1、线程是抢占式执行的,线程间的调度充满随机性。(线程不安全的根本原因)

2、多个线程对同一个变量进行修改操作。

3、针对变量的操作不是原子的,通过加锁操作就是把几个指令打包成一个原子的。

4、内存可见性。

什么是内存可见性呢?

假设我们这里有两个线程t1,t2;t1只进行读操作,t2在合适的时候会进行修改操作。

t1 这个线程在循环读这个变量。那么读取内存操作,相比于读取寄存器,是一个非常低效的操作作。 (慢 3-4 个数量级)
因此在 t1 中频繁的读取这里内存的值就会非常低效。
而且如果 t2 线程迟迟不修改,t1 线程读到的值又始终是一样的值!!
因此,t1 可能会 直接从寄存器里读(即不执行 load )一旦 t1 做出了这种大胆的假设,此时万一 t2 修改了 count 值, t1 就不能感知到了。

代码演示:

import java.util.Scanner;

public class demo16 {
    public static int isquit = 0;
    public static void main(String[] args) {
        Thread t = new Thread(()-> {
            while (isquit == 0){

            }
            System.out.println("循环结束,t线程退出!");
        });
        t.start();

        Scanner sc = new Scanner(System.in);
        System.out.println("请输入一个isquit的值:");
        isquit = sc.nextInt();
        System.out.println("main线程执行完毕!");
    }
}

运行结果:

 那么这个案例就很好的说明了上述内存可见性的问题,我们手动输入isquit的值为2,那么while循环结束按理说应该打印 System.out.println("循环结束,t线程退出!");正是因为t线程一直反复读isquit的值,于是它直接从寄存器读,那么我们修改了isquit的值,它也就感知不到了。所以就没有打印 循环结束,t线程退出! 这条语句。

解决方案?

1、使用synchronized 关键字。synchronized 不光能够保证原子性,同时也能够保证内存可见性。被synchronized 包裹起来的代码,编译器就不敢轻易做出上述假设,就相当于手动禁止了编译器的优化。

2、使用volatile关键字。volatile和原子性无关,但是能够保证内存可见性。使得编译器每次都重新从内存中读取isquit的值。

    public static volatile int isquit = 0;

 5、指令重排序

这个操作也是编译器优化的一种操作,编译器会智能的调整代码的前后顺序从而提高程序的效率。

保证逻辑不变的前提,再去调整顺序。使用synchronized 也能够禁止指令从排序!!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/111054.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

抗癌药物之多肽药物偶联物技术(PDC)介绍

长期以来&#xff0c;心血管疾病是全球中年人死亡的主要原因。这种情况最近在高收入国家发生了变化&#xff0c;现在癌症导致的死亡人数是心血管疾病的两倍。2018 年&#xff0c;癌症导致全球 960 万人死亡&#xff0c;1810 万新病例被诊断出来。女性最常发生的癌症是乳腺癌&am…

12Python继承与多态

继承 面向对象三大特性 封装 根据 职责 将 属性 和 方法 封装 到一个抽象的 类 中继承 实现代码的重用&#xff0c;相同的代码不需要重复的编写多态 不同的对象调用相同的方法&#xff0c;产生不同的执行结果&#xff0c;增加代码的灵活度 1继承的概念、语法和特点 继承的概…

奖项快报 | ALVA Systems 上榜 《2022 高成长企业 TOP100》!

近日&#xff0c;《2022 高成长企业 TOP 100》榜单发布&#xff0c;凭借卓越的创新能力与在工业 AR 领域的赋能价值&#xff0c;ALVA Systems 在2022年度高成长企业TOP100大赛活动中脱颖而出&#xff0c;成功入选榜单。 *ALVA Systems 入选榜单 创新驱动&#xff0c;赋能数字经…

【ARM -- stm32 汇编代码点亮LED灯】

ARM -- stm32 汇编代码点亮LED灯实现过程查询开发手册分析RCC章节分析GPIO章节编写代码实现过程 查询开发手册 分析RCC章节 一、确定RCC基地址 二、分析RCC_MP_AHB4ENSETR寄存器 1、RCC_MP_AHB4ENSETR寄存器的功能是使能GPIO组相关控制器&#xff1b; 2、RCC_MP_AHB4ENSET…

07第四章:01_常用注解

常用注解 1、Table 作用&#xff1a;建立实体类和数据库表之间的对应关系。 默认规则&#xff1a;实体类类名首字母小写作为表名&#xff0c;如 Employee -> employee 表 用法&#xff1a;在 Table 注解的 name 属性中指定目标数据库的表名&#xff1b; 案例&#xff1…

WPF依赖属性、附加属性、属性继承、类型转换详解

依赖属性 依赖属性回调方法与参数 具有依赖属性的类必须继承自DependencyObject&#xff0c;定义依赖属性要有2个步骤 //1属性包装器&#xff0c;目的是为了向正常属性一样使用依赖属性 public int Name {get { return (int)GetValue(NameProperty); }set { SetValue(NamePr…

国家“数据安全三认证”图解来了

二十大指引新时代新征程。蓝图已经绘就&#xff0c;号角已经吹响&#xff0c;新征程是充满光荣和梦想的远征。二十大报告深刻阐明了实现中华民族伟大复兴的一系列重大问题&#xff0c;系统擘画了以中国式现代化推进民族复兴的宏伟蓝图&#xff0c;是引领中华民族伟大复兴的政治…

论文导读 | GPU上的动态图数据管理技术浅析

一、背景介绍 随着相关技术的发展&#xff0c;图计算与分析系统在大量场景中得到应用。同时&#xff0c;为了解决图规模巨大等因素导致的性能下降问题&#xff0c;研究人员利用GPU这一新型计算硬件&#xff0c;设计了大量高效的图计算与分析解决方案。GPU提供的高并发计算能力…

我司何晓磊受邀参加东盟与中日韩中小企业人工智能产业论坛并担任评委

我司何晓磊受邀参加东盟与中日韩中小企业人工智能产业论坛并担任评委 一、活动背景 为推动东盟与中日韩&#xff08;103&#xff09;中小企业服务联盟务实合作&#xff0c;帮助中小企业提高生产力和技术创新能力&#xff0c;进一步提高国际化发展水平&#xff0c;促进东亚区域…

C++——哈希练习题

文章目录一、编程题1.在长度 2N 的数组中找出重复 N 次的元素2. 两个数组的交集二、面试题给40亿个不重复的无符号整数&#xff0c;没排过序。给一个无符号整数&#xff0c;如何快速判断一个数是否在这40亿个数中。【腾讯】&#xff08;一&#xff09;位图应用1. 给定100亿个整…

C++ :STL:初识

1&#xff1a;STL初识 1.1 STL的诞生 STL 诞生来源 长久依赖&#xff0c;软件界一直希望建立一种可重复利用的东西C 的面向对象和泛型思想&#xff0c;目的就是复用性的提升大多数情况下&#xff0c;数据结构和算法都未能有一套标准&#xff0c;导致被迫从事大量重复的工作为了…

多线程问题(一)

目录 一、为什么引入线程&#xff1f; 二、线程和进程的区别 三、创建线程的五种方式 1、创建类继承Thread类 2、创建类实现Runnable接口 3、构造Thread类的匿名内部类 4、构造Runnable的匿名内部类 5、使用lambda表达式 四、start方法与run方法的区别 五、线程…

Promise对象的使用

一、什么是Promise Promise 是异步编程的一种解决方案&#xff0c;比传统的解决方案&#xff08;回调函数和事件&#xff09;更合理和更强大。从语法上说&#xff0c;Promise 是一个对象&#xff0c;从它可以获取异步操作的消息。Promise 提供统一的 API&#xff0c;各种异步操…

攻略丨在小红书高效种草,品牌要问的7个问题

这个圣诞节&#xff0c;小羊人和冬阴功&#xff08;这个冬天依然阴着的打工人&#xff09;们各怀心事&#xff0c;最有圣诞氛围的地方要数小红书了。打开首页就能看到&#xff0c;宅家自制光影圣诞树&#xff0c;被安利好利来蛋糕&#xff0c;再往下滑一滑&#xff0c;还有圣诞…

[开源工具]2022免费临时邮箱(Temp Free Mail)

2022免费临时邮箱Temp Free Mail1、10分钟邮箱2、45分钟邮箱3、60分钟邮箱4、24小时邮箱5、5日邮箱6、其他临时邮箱7、无时间限制临时邮箱8、临时邮箱常见问题答疑临时邮箱&#xff0c;英文名称 Temp Mail&#xff0c;也被称为一次性邮箱或匿名邮箱&#xff0c;根据它的邮件有效…

Vue - npm 批量升级依赖包

参考&#xff1a; npm 如何更新项目最新依赖包 一行命令更新所有 npm 依赖包 npm 升级依赖包 批量升级有风险&#xff01;&#xff01;&#xff01;升级需谨慎&#xff01;&#xff01; 常规的包升级方式 npm update (包) 检查项目可升级的包 方式一 该命令将检查每个已安装的…

初识C++ - 类与对象(下篇·下)

目录 再谈构造函数 隐式类型的转换 explicit关键字 单参数 多参数 static静态 一道关于static的题目 友元 友元函数 友元类 内部类 匿名对象 拷贝对象时的一些编译器优化 结束语 再谈构造函数 1.1 构造函数体赋值 在创建对象时&#xff0c;编译器通过调用构造函…

服装进销存管理软件哪个比较好用?

做好库存是服装行业是保障店铺正常运营重要方面。如果只是靠人工清点记录服装库存情况、手工记账&#xff0c;会花费大量的人员和精力&#xff0c;还不能保证一定的效率和准确率。而且服装业具有鲜明的行业特性&#xff1a;服装款式多、季节性强、颜色/尺码等等&#xff0c;如果…

Influxdb双写服务influxdb-relay部署配置【离线】

Background Influxdb社区版未提供集群方案&#xff0c;官方提供的集群模式为闭源收费版本&#xff0c;具体收费明细不太清楚哈&#xff0c;有知道的请留言告知哈。官方开源的influxdb-relay仅仅支持双写功能&#xff0c;并未支持负载均衡能力&#xff0c;仅仅解决了数据备份的问…

【C++初阶】友元(友元函数友元类)、内部类、匿名对象、拷贝对象时的优化

&#x1f31f;hello&#xff0c;各位读者大大们你们好呀&#x1f31f; &#x1f36d;&#x1f36d;系列专栏&#xff1a;【C学习与应用】 ✒️✒️本篇内容&#xff1a;友元函数和友元类的概念和基础应用&#xff0c;简单介绍内部类、匿名对象、拷贝对象时的部分编译器优化情况…