【JavaEE-多线程背景-线程等待-线程的六种状态-线程安全问题-详解】

🌈个人主页：SKY-30
⛅个人推荐：基于java提供的ArrayList实现的扑克牌游戏 |C贪吃蛇详解
⚡学好数据结构，刷题刻不容缓：点击一起刷题
🌙心灵鸡汤：总有人要赢，为什么不能是我呢
在这里插入图片描述

在这里插入图片描述

🌈🌈🌈Java的多线程

⚡⚡⚡多线程的背景

为了充分利用cpu的多核心特性,我们引进了一种新的编程形式,并发编程,当然进程也可以进行并发编程,但是进程太"重"了,我们每次创建一个进程需要耗费很大的资源,对于有些业务场景可能需要对进程频繁的创建和删除,所以我们又引进了一个更轻量的进程-线程.

在这里插入图片描述

⚡⚡⚡多线程和多进程的联系

线程包含在进程之中,一个进程中至少包含一个或多个线程,对于线程来说它比进程创建和销毁的成本更小,并且一个进程中的多个线程是公用一份系统资源的(硬盘,网络带宽,内存…).

进程是操作系统资源分配的基本单位

线程是操作系统调度执行的基本单位

在这里插入图片描述

🌈🌈🌈在Java中使用多线程

==在Java中我们使用Java标准库中的Thread对象实现多线程.==对于实现Java的多线程我们这里有多种方式,这里给大家全部列举出来.

🌈🌈🌈创建线程

⚡⚡⚡⚡实现Thread类

我们可以实现一个继承了Thread类的类,然后重写run方法,在run方法中完成多线程的代码逻辑.然后再main方法中实例化对象,启动线程.

// 定义一个Thread类，相当于一个线程的模板
class MyThread01 extends Thread {// 重写run方法// run方法描述的是线程要执行的具体任务@Overridepublic void run() {System.out.println("hello, thread.");}
}/*** 继承Thread类并重写run方法创建一个线程** */
public class Thread_demo01 {public static void main(String[] args) {// 实例化一个线程对象MyThread01 t = new MyThread01();// 真正的去申请系统线程，参与CPU调度t.start();}
}

⚡⚡⚡实现Runnable接口

这里我们也可以通过实现Runnable接口,然后实现run方法,实现多线程.然后将Runnable以参数的形式传递给Thread类,完成线程的创建.

// 创建一个Runnable的实现类，并实现run方法
// Runnable主要描述的是线程的任务
class MyRunnable01 implements Runnable {@Overridepublic void run() {System.out.println("hello, thread.");}
}
/*** 通过继承Runnable接口并实现run方法* * */
public class Thread_demo02 {public static void main(String[] args) {// 实例化Runnable对象MyRunnable01 runnable01 = new MyRunnable01();// 实例化线程对象并绑定任务Thread t = new Thread(runnable01);// 真正的去申请系统线程参与CPU调度t.start();}
}

⚡⚡⚡使用匿名内部类实现线程

由于我们上面的几种创建方式,都是利用继承和接口的形式,通过匿名内部类的学习,我们很容易想到我们完全可以利用匿名内部类实现一个线程,大大简化了代码的复杂性,是一种比较流行的形式.

/*** 通过Thread匿名内部类的方法创建一个线程* **/
public class Thread_demo03 {public static void main(String[] args) {Thread t = new Thread(){// 指定线程任务@Overridepublic void run() {System.out.println(Thread.currentThread().getName());}};// 真正的申请系统线程参与CPU调度t.start();}
}

⚡⚡⚡通过Runnable匿名内部类创建一个线程

*** 通过Runnable匿名内部类创建一个线程* **/
public class Thread_demo04 {public static void main(String[] args) {Thread t = new Thread(new Runnable() {// 指定线程的任务@Overridepublic void run() {System.out.println(Thread.currentThread().getName());                }});// 申请系统线程参与CPU调度t.start();}
}

⚡⚡⚡利用lambda表达式

不知道大家是否记得.lambda表达式的使用场景,就是这个类只用一次,并且这里必须是函数式接口,才可以使用,这里我们的Runnable就是函数式接口

在这里插入图片描述
所以这里我们也可以使用lambda表达式实现一个线程

/*** 通过Lambda表达式的方式创建一个线程*/
public class Thread_demo05 {public static void main(String[] args) {Thread t = new Thread(() -> {// 指定任务：任务是循环打印当前线程名while (true) {System.out.println(Thread.currentThread().getName());try {// 休眠1000msThread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}});// 申请系统线程参与CPU调度t.start();}
}

🌈🌈🌈Java中多线程的重要属性

在这里插入图片描述
这里强调一下==isDaemon()==方法,可以判定是否为后台线程即后台线程不会影响进程的运行,而前台线程结束时会关闭当前的进程的运行.

还有就是getState()获取当前线程的状态,一种有六种状态,这个我们后面再说

🌈🌈🌈启动线程

我们上面说了,可以以来Thread即java的标准库中的类来实现一个线程对象,但是,想要真正启动一个线程还是远远不够的,我们还需要依赖一个方法start(),来启动线程,只有调用了start这个方法,线程才会真正运行,这里还经常会有哦一个面试题:

run方法和start方法有什么区别???

run方法:它是线程的入口,在run方法内部我们完成线程内部要执行的代码,相当于线程的主题内容
start方法:它是线程真正启动的标志,只有当前对象调用了start方法,线程才会真正运行.

特别说明:一个线程,只能调用一次start方法

🌈🌈🌈线程终止

对于一个线程来说,要想终止,只能加快run方法的执行,将run方法结束,来结束线程.这里我们利用interrupt方法终止线程,并且这个方法还会设置一个标志位.

public class ThreadInterruptExample {public static void main(String[] args) {Thread thread = new Thread(() -> {try {while (!Thread.currentThread().isInterrupted()) {System.out.println("Thread is running...");Thread.sleep(1000); // 模拟一些工作}} catch (InterruptedException e) {System.out.println("Thread was interrupted!");}System.out.println("Thread is exiting.");});thread.start(); // 启动线程try {Thread.sleep(2500); // 等待2.5秒} catch (InterruptedException e) {e.printStackTrace();}thread.interrupt(); // 请求中断线程}
}

这里就是在main方法中通过interrupt方法终止线程thread,然后开始执行main中的剩余代码.

特别说明interrupt方法执行之后,还会将sleep的线程唤醒,并且清空标志位

public class ThreadInterruptExample {public static void main(String[] args) {Thread thread = new Thread(() -> {try {while (true) {System.out.println("Thread is running...");Thread.sleep(1000); // 模拟阻塞状态}} catch (InterruptedException e) {System.out.println("Thread was interrupted!");return; // 退出线程}});thread.start(); // 启动线程try {Thread.sleep(2500); // 主线程等待2.5秒} catch (InterruptedException e) {e.printStackTrace();}thread.interrupt(); // 请求中断线程}
}

我们创建了一个线程，该线程在无限循环中运行，并每1秒打印一次消息。
线程在循环中调用sleep(1000)，模拟阻塞状态。
在主线程中，我们让线程运行2.5秒。
然后，我们调用线程的interrupt()方法，这会请求中断线程。
当线程的sleep()方法被中断时，会抛出InterruptedException。这个异常会清除线程的中断状态，并且线程会退出。

⚡⚡⚡线程等待

对于多个线程来货,CPU遵循的原则是随机调度,抢占式执行.,然后后面的线程就会进入我们无法控制线程的执行,但是我们控制线程的结束顺序,即我们让后结束的线程等待先结束的线程,这里把将后结束的线称为等待状态,我们一般叫做-阻塞状态.这种阻塞状态直到被等待线程执行完毕之后才能开始执行.

那么我们如何控制线程的结束顺序呢,一般通过join这个方法来控制,比如说现在有两个线程,a,b我们在a线程中调用一个b.join()此时就会使b线程先执行,a线程陷入阻塞状态,直到b执行完毕,a才能开始执行.

public class Main {public static void main(String[] args) {Thread worker = new Thread(new Runnable() {public void run() {System.out.println("Worker thread is running.");try {Thread.sleep(2000); // 模拟工作线程执行任务需要2秒} catch (InterruptedException e) {e.printStackTrace();}System.out.println("Worker thread has finished.");}});worker.start(); // 启动工作线程try {worker.join(); // 主线程等待工作线程完成} catch (InterruptedException e) {e.printStackTrace();}System.out.println("Main thread is continuing after worker thread has finished.");}
}

这里的join就是主线程在等待worker执行完毕之后,主线程才开始执行,主线程在这个过程中处于阻塞状态.

⚡⚡⚡join()方法

对于这个方法来说,它可以决定线程的等待状态,然而,如果被等待线程如果出现了一些bug,那么等待线程就会一直处于等待状态,即"死等状态",但是显然这种状态并不是我们想要的,所以join方法就给我们提供了两种版本,有参数和无参数版本,无参数即可能陷入死等状态,有参数即可以设置等待的时间单位为毫秒,时间结束不管被等待线程有没有执行完毕,都会结束这个join方法.

🌈🌈🌈线程的状态

对于进程来说,大致分为两种状态,就绪状态和阻塞状态.
就绪状态:正在运行,或者随时可以调到CPU上执行.
阻塞状态:线程处于等待状态,不能立刻执行

然而对于线程来说,他的状态就远远不止这两种了~~
线程一共有六种状态,这里给大家列举出来

NEW

此时线程的Thread对象已经创建完成,但是还没有启动线程,即没有调用start方法,此时的状态称为NEW,可以利用getState方法获取线程的状态

public class Test {public static void main(String[] args) {Thread worker = new Thread(new Runnable() {public void run() {System.out.println("Worker thread is running.");try {Thread.sleep(2000); // 模拟工作线程执行任务需要2秒} catch (InterruptedException e) {e.printStackTrace();}System.out.println("Worker thread has finished.");}});System.out.println( worker.getState());worker.start(); // 启动工作线程try {worker.join(); // 主线程等待工作线程完成} catch (InterruptedException e) {e.printStackTrace();}System.out.println("Main thread is continuing after worker thread has finished.");}
}

运行结果:
在这里插入图片描述

⚡⚡⚡TERMINATED

此时的线程已将结束了,但是Thread类对象还没有销毁…

public class Main {public static void main(String[] args) {Thread worker = new Thread(new Runnable() {public void run() {System.out.println("Worker thread is running.");try {Thread.sleep(2000); // 模拟耗时操作} catch (InterruptedException e) {Thread.currentThread().interrupt(); // 重新设置中断状态}System.out.println("Worker thread has finished.");}});worker.start(); // 启动线程while (!worker.getState().equals(Thread.State.TERMINATED)) {System.out.println("Main thread is waiting for worker thread to finish.");try {Thread.sleep(1000); // 每1秒检查一次} catch (InterruptedException e) {Thread.currentThread().interrupt(); // 重新设置中断状态}}System.out.println("Worker thread is in TERMINATED state.");}
}

⚡⚡⚡BLOCKED

这是由于锁竞争导致的阻塞,这里我们还没有引入锁所以先跳过

⚡⚡⚡RUNNABLE

就绪状态:正在运行或者随时可以调度到CPU执行

public class Test {public static void main(String[] args) {Thread worker = new Thread(new Runnable() {public void run() {System.out.println( Thread.currentThread().getState());System.out.println("Worker thread is running.");try {Thread.sleep(2000); // 模拟工作线程执行任务需要2秒} catch (InterruptedException e) {e.printStackTrace();}System.out.println("Worker thread has finished.");}});//System.out.println( worker.getState());worker.start(); // 启动工作线程try {worker.join(); // 主线程等待工作线程完成} catch (InterruptedException e) {e.printStackTrace();}System.out.println("Main thread is continuing after worker thread has finished.");}
}

运行结果
在这里插入图片描述

⚡⚡⚡TIMED_WAITING和WAITING

这两种状态其实就是我们上面提到的一个是处于有时间的暂时等待,另一个则是无限制的死等,即可以利用join的两个版本实现这两个状态.对于有时间的,也可以用sleep检验…

🌈🌈🌈🌈线程安全

在多线程的概念中,线程安全是非常重要的一个知识点,一定要认真巩固,那么线程安全从何而来呢,这里就是因为多线程编程的底层原理,随机调度,抢占式执行,在这样的机制下就会导致线程安全的问题,为了让大家了解的更清楚,给大家举一个例子.

public class MyThreadDemo1 {public static int count=0;public static void main(String[] args) throws InterruptedException {Thread t1=new Thread(()->{for(int i=0;i<50000;i++){count++;}});Thread t2=new Thread(()->{for(int i=0;i<50000;i++){count++;}});t1.start();t2.start();t1.join();t2.join();System.out.println(count);}
}

这里运行出来的结果就并非是100000,原因是内存中的count值没有及时更新

这里的count++其实不仅仅是一步操作,对于CPU来说其实一共有三步操作:

  • load:将数据从内存中加载到寄存器中
  • add:寄存器中的数值执行++操作
  • save:保存sount的值并更新内存中的count的值

然而对于多线程来说,随时都可能被其他线程占据cpu的运行资源,由于cpu的最小执行单位是指令,所以起码每次执行终止都会让当前的指令执行完毕.
这样的机制就会导致线程安全问题,下面给大家画图演示一下.
在这里插入图片描述
此时就会出现t2虽然count值已经加一,但是没有及时更新内存(方块)中的count值,所以导致后面t1加载count时还是0所以后面的count的值就是1

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

C语言实现冒泡排序

C语言实现冒泡排序

冒泡排序是一种简单的排序算法&#xff0c;它重复地遍历要排序的数列&#xff0c;一次比较两个元素&#xff0c;如果它们的顺序错误就把它们交换过来。 遍历数列的工作是重复地进行直到没有再需要交换&#xff0c;也就是说该数列已经排序完成。这个算法的名字由来是因为越小的元…
阅读更多...
数据包的跨层封装

数据包的跨层封装

首先&#xff0c;我们先简单地分析一下数据包的组成结构&#xff1a; 如图 数据包简略地分为以下几层&#xff1a; 二层&#xff1a;封装MAC地址&#xff08;数据链路层&#xff09; 三层&#xff1a;封装IP地址 — 表明源IP和目标IP&#xff0c;主要用于路由器之间的信息转发…
阅读更多...
【人工智能】Transformers之Pipeline（三）：文本转音频（text-to-audio/text-to-speech）

【人工智能】Transformers之Pipeline（三）：文本转音频（text-to-audio/text-to-speech）

​​​​​​​ 一、引言 pipeline&#xff08;管道&#xff09;是huggingface transformers库中一种极简方式使用大模型推理的抽象&#xff0c;将所有大模型分为音频&#xff08;Audio&#xff09;、计算机视觉&#xff08;Computer vision&#xff09;、自然语言处理&#x…
阅读更多...
挖矿宝藏之硬盘分区

挖矿宝藏之硬盘分区

目录 一、硬盘分区的相关知识 二、主分区、活动分区、扩展分区、逻辑盘和盘符 三、硬盘分区原因 1.减少硬盘空间的浪费 2.便于文件的分类管理 3.有利于病毒的防治 四、硬盘分区的原则 1.方便性 2.实用性 3.安全性 五、利用Diskpart进行分区 1.命令行工具Diskpart …
阅读更多...
ARM体系结构和接口技术（五）封装RCC和GPIO库

ARM体系结构和接口技术（五）封装RCC和GPIO库

文章目录 一、RCC&#xff08;一&#xff09;思路1. 找到时钟基地址2. 找到总线的地址偏移&#xff08;1&#xff09;AHB4总线&#xff08;2&#xff09;定义不同GPIO组的使能宏函数&#xff08;3&#xff09;APB1总线&#xff08;4&#xff09;定义使能宏函数 二、GPIO&#x…
阅读更多...
捷配笔记-混合信号PCB布局设计的基本准则是什么？

捷配笔记-混合信号PCB布局设计的基本准则是什么？

混合信号PCB设计需要对模拟和数字电路有基本的了解&#xff0c;以最大限度地减少&#xff08;如果不能防止的话&#xff09;信号干扰。现代系统由数字域和模拟域均可操作的组件组成&#xff0c;这些组件必须经过精心设计&#xff0c;以确保整个系统的信号完整性。 在混合信号系…
阅读更多...
MySQL学习记录 —— 이십이 MySQL服务器文件系统（2）

MySQL学习记录 —— 이십이 MySQL服务器文件系统（2）

文章目录 1、日志文件的整体简介2、一般、慢查询日志1、一般查询日志2、慢查询日志FILE格式TABLE格式 3、错误日志4、二进制日志5、日志维护 1、日志文件的整体简介 中继服务器的数据来源于集群中的主服务。每次做一些操作时&#xff0c;把操作保存到重做日志&#xff0c;这样崩…
阅读更多...
vscode+wsl2+anaconda环境的配置与使用

vscode+wsl2+anaconda环境的配置与使用

目录 下载anaconda Anaconda使用参考 vscodeubuntuanaconda 先用vscode连接本地ubuntu。 如果没有安装wsl2与ubuntu&#xff0c;可点击下面的链接。 问题&#xff1a;wsl install 无法解析服务器 成功记录&#xff1a; 在vscode终端用ubuntu安装anaconda。 创建pytho…
阅读更多...
Spring如何管理Mapper

Spring如何管理Mapper

目录 一、背景二、猜测三、源码查看步骤1、创建MapperScannerConfigurer.java2、MapperScan注解3、MapperScannerRegistrar执行registerBeanDefinitions方法4、MapperScannerConfigurer执行postProcessBeanDefinitionRegistry方法5、执行doscan6、设置beanClass7、使用jdk生成代…
阅读更多...
万界星空科技电线电缆MES系统实现线缆全流程追溯

万界星空科技电线电缆MES系统实现线缆全流程追溯

MES系统通过高度集成的数据平台&#xff0c;对电线电缆的生产全过程进行实时监控与记录&#xff0c;从原材料入库开始&#xff0c;到生产过程中的各个关键控制点&#xff0c;再到成品出库&#xff0c;每一步操作都被详细记录并可追溯。这种全流程追溯能力主要体现在以下几个方面…
阅读更多...
在组件中显示tuku的照片

在组件中显示tuku的照片

一、问题 &#xff08;1&#xff09;错误&#xff1a;域名前面一定要加http://要不然会报错 &#xff08;2&#xff09;在使用 defineModel传值时一定要动态绑定&#xff0c;要不然图片不显示 &#xff08;3&#xff09;改完后在商品列表中显示图片信息必须 在显示的图片中取…
阅读更多...
Linux入门笔记(指令)

Linux入门笔记(指令)

操作系统是什么&#xff1f; 操作系统是一款做软硬件管理的软件。计算机系统自下而上可以大致分为4部分&#xff1a;硬件、操作系统、应用程序和用户。操作系统管理各种计算机硬件&#xff0c;为应用程序提供基础&#xff0c;并且充当计算机硬件与用户之间的中介。重点&#x…
阅读更多...
Mybatis——生命周期和作用域

Mybatis——生命周期和作用域

理解不同作用域和生命周期类别是至关重要的&#xff0c;因为错误的使用会导致非常严重的并发问题。 SqlSessionFactoryBuilder&#xff1a; 一旦创建了 SqlSessionFactory&#xff0c;就不再需要它了。 局部方法变量 SqlSessionFactory&#xff1a; 可以想象为&…
阅读更多...
力扣145题：二叉树的后序遍历

力扣145题：二叉树的后序遍历

给你一棵二叉树的根节点 root &#xff0c;返回其节点值的 后序遍历 。 示例 1&#xff1a; 输入&#xff1a;root [1,null,2,3] 输出&#xff1a;[3,2,1]示例 2&#xff1a; 输入&#xff1a;root [] 输出&#xff1a;[]示例 3&#xff1a; 输入&#xff1a;root [1] 输出…
阅读更多...
C++复习的长文指南

C++复习的长文指南

C复习的长文指南 一、入门语法知识1.预备1.1 main函数1.2 注释1.3 变量1.3 常量1.4 关键字1.5 标识符明明规则 2. 数据类型2.1 整型2.1.1 sizeof关键字 2.2 实型&#xff08;浮点型&#xff09;2.3 字符型2.4 转义字符2.5 字符串型2.6 布尔类型bool2.7 数据的输入 3. 运算符3.1…
阅读更多...
SwiftUI 6.0（Xcode 16）新 PreviewModifier 协议让预览调试如虎添翼

SwiftUI 6.0（Xcode 16）新 PreviewModifier 协议让预览调试如虎添翼

概览 用 SwiftUI 框架开发过应用的小伙伴们都知道&#xff0c;SwiftUI 中的视图由各种属性和绑定“扑朔迷离”的缠绕在一起&#xff0c;自成体系。 想要在 Xcode 预览中泰然处之的调试 SwiftUI 视图有时并不是件容易的事。其中&#xff0c;最让人秃头码农们头疼的恐怕就要数如…
阅读更多...
对redis进行深入学习

对redis进行深入学习

目录 1. 什么是redis&#xff1f;1.1 为什么使用redis作为缓存&#xff1f;1.1.0 数据库&#xff08;MySQL&#xff09;与 redis1. 存储介质不同&#xff08;408选手应该都懂hh&#xff09;2. 数据结构优化3. I/O模型差异4. CPU缓存友好性5. 单线程与多线程差异6. 持久化与缓存…
阅读更多...
进程的地址空间

进程的地址空间

一、写个代码见一见地址空间 1、问题 在代码中我们在第五秒时会在子进程中改变全局变量 g_val 但是我们发现了一个奇怪的现象&#xff1a;在子进程中改变 g_val &#xff0c;由于进程的独立性&#xff0c;所以子进程和父进程的值不一样是可以理解的&#xff0c;但是为什么变量…
阅读更多...
【C++11】线程

【C++11】线程

本篇文章更多的是熟悉一下C11的线程库接口&#xff0c;与linux的相关线程接口是非常相似的&#xff0c;更多的是将面向过程改为了面向对象。 并没有一些概念的讲解。 想知道线程的相关概念的可以看一看这篇文章及后续 在C11之前&#xff0c;涉及到多线程问题&#xff0c;都是和…
阅读更多...
访问控制系列

访问控制系列

目录 一、基本概念 1.客体与主体 2.引用监控器与引用验证机制 3.安全策略与安全模型 4.安全内核 5.可信计算基 二、访问矩阵 三、访问控制策略 1.主体属性 2.客体属性 3.授权者组成 4.访问控制粒度 5.主体、客体状态 6.历史记录和上下文环境 7.数据内容 8.决策…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023