【JavaEE】——多线程(join阻塞,计算,引用,状态)

阿华代码,不是逆风,就是我疯,你们的点赞收藏是我前进最大的动力!!希望本文内容能够帮助到你!

目录

一:join等待线程结束

1:知识回顾

2:join的功能就是“阻塞等待”

3:谁调用谁等待

4:join和“优先级”区分

二:多线程运行计算

1:情景引入

2:多线程提升进程的运行效率

(1)代码分析

3:串行执行

三:获取线程的引用

1:Thread.currentThread():

2:创建线程方式影响this引用

3:代码举例如下

四:线程的状态

0:.getState()

1: NEW

2:TERMINATED

3:RUNNABLE

4:TIME_WAITING

5:WAITING

6:BLOCK


引入:通过上一篇文章的学习,我们知道可以通过用Thred的sleep方法,让main函数这个线程进行沉睡,进而达到,让其它线程先执行完毕,main函数在执行这种目的。但是如果不清楚其他线程何时结束,就不能使用sleep方法了

一:join等待线程结束

1:知识回顾

(1)多线程的调度是无序的(随机调度,抢占式执行)

(2)可以通过操作系统提供的一系列api来控制线程的执行顺序

2:join的功能就是“阻塞等待”

如果t1这个线程还在运行,main函数就必须等着,这就是“阻塞等待”。(可以理解成插队,我join到你前面了,一定是我先买到票走人)(阅读以下代码加深理解)

3:谁调用谁等待

因为实在main函数中,t1join进去的,所以main函数等待。如果现在有t1,t2,两个线程都join了呢?——t1 , t2 并发执行,随机调度,两者都执行完毕了,main函数才能执行

4:join和“优先级”区分

join不是确定“执行顺序”而是确定“结束顺序”,本质是让调用操作系统的api进行控制,让main函数放弃去“调度器”中调度。

package thread;/*** Created with IntelliJ IDEA.* Description:* User: Hua YY* Date: 2024-09-20* Time: 20:34*/
public class ThreadDemon14 {public static void main(String[] args) throws InterruptedException {Thread t1 = new Thread(()->{for (int i = 0; i < 5; i++) {System.out.println("t1线程正在运行");try {Thread.sleep(500);} catch (InterruptedException e) {throw new RuntimeException(e);}}});t1.start();t1.join();System.out.println("这里是main函数线程,我需要等待t1线程执行完毕,才能进行打印");}
}

二:多线程运行计算

1:情景引入

问题:我们用单线程和多线程去计算前1_0000_0000个数字之和,看两者速度差多少

2:多线程提升进程的运行效率

(1)代码分析

下面第一个代码——兵分三路:①main,②算1~5000_0000 ,③算5000_0001~1_0000_0000。本质上来说是  (并发执行=并行+并发) ②③在不同的核心上(并行) ,②③同时运行(并发)

不懂得可以看我前面写过的文章哦!有举例子。

package thread;/*** Created with IntelliJ IDEA.* Description:* User: Hua YY* Date: 2024-09-19* Time: 14:13*/
public class ThreadDemon15 {private static long result = 0;public static void main(String[] args) throws InterruptedException {//用多线程去计算前多少个数字之和Thread thread = new Thread(()->{long tem = 0;for (long i = 0; i < 5000_0000L; i++) {tem += i ;}result += tem ;});Thread thread2 = new Thread(()->{//thread.join();//又变成了串行执行了,并非并发执行long tem = 0;for (long i = 5000_0001 ; i < 1_0000_0000L ; i++) {tem += i;}result += tem;});thread.start();//创建一个新的线程,新的线程跟之前的线程是"并发执行"的关系thread2.start();long beg = System.currentTimeMillis();//记录开始时间//main函数线程阻塞,等待thread线程运行thread.join();thread2.join();//确保thread进程执行完毕在执行main函数long end = System.currentTimeMillis();//记录结束时间System.out.println("双线程的计算结果是:" + result);System.out.println("双线程用到的时间是:" + (end - beg) );}
}

package thread;/*** Created with IntelliJ IDEA.* Description:* User: Hua YY* Date: 2024-09-20* Time: 21:03*/
public class ThreadDemon15_2 {private static long result = 0;public static void main(String[] args) throws InterruptedException {//用多线程去计算前多少个数字之和Thread thread = new Thread(()->{long tem = 0;for (long i = 0; i < 1_0000_0000L; i++) {tem += i ;}result += tem ;});thread.start();//创建一个新的线程,新的线程跟之前的线程是"并发执行"的关系long beg = System.currentTimeMillis();//记录开始时间//main函数线程阻塞,等待thread线程运行thread.join();long end = System.currentTimeMillis();//记录结束时间System.out.println("单线程的计算结果是:" + result);System.out.println("单线程用到的时间是:" + (end - beg) );}
}

3:串行执行

有没有办法让第一个线程结束,在进行第二个线程,最后执行main函数

三:获取线程的引用

1:Thread.currentThread():

获取到当前线程的引用(Thread引用)

2:创建线程方式影响this引用

如果继承的是Thread类,那么可以用this拿到线程的引用

如果是Runnable或者lambda的方式创建线程,this不能指向Thread对象了,那么此时this就不可以用了,就只能使用Thread.currentThread。

3:代码举例如下

package thread;/*** Created with IntelliJ IDEA.* Description:* User: Hua YY* Date: 2024-09-19* Time: 16:18*/
class MyThread5 extends Thread{@Overridepublic void run() {System.out.println(this.getId() + "," + this.getName());}
}
public class ThreadDemon16 {public static void main(String[] args) throws InterruptedException {/** t1,t2 的先后顺序是不确定的,线程的随机调度*/Thread t1 = new MyThread5();Thread t2 = new MyThread5();t1.start();t2.start();Thread.sleep(1000);System.out.println(t1.getId() + t1.getName());System.out.println(t2.getId() + t2.getName());}}

package thread;/*** Created with IntelliJ IDEA.* Description:* User: Hua YY* Date: 2024-09-19* Time: 16:27*/
public class ThreadDemon17 {/** 使用lambda表达式和Runnable接口写法,就不能用this了*lambda中没有指向任何对象,this没法用* Runnable写法则是this指向的是Runnable* 所以只能用.currentThread这个方法来获取当前*/public static void main(String[] args) {Thread t1 = new Thread(()->{Thread t = Thread.currentThread();System.out.println(t.getId()+t.getName());});Thread t2 = new Thread(()->{Thread t = Thread.currentThread();System.out.println(t.getId()+t.getName());});t1.start();t2.start();}}

四:线程的状态

通过之前的学习,我们知道线程有就绪和阻塞两种状态。下面我们进行更深入的学习

0:.getState()

获取线程的状态

1: NEW

创建了Thread对象,但是还没有调用start方法,线程还没有运行起来

2:TERMINATED

terminated终止状态,一个线程已经执行完毕,但是Thread对象还存在,

3:RUNNABLE

runnable状态,线程正在cpu上运行,或者准备就绪,随时可以上cpu运行

4:TIME_WAITING

time_waiting状态, 多为sleep和join引起的带有一定时间的阻塞等待

5:WAITING

waiting状态,(线程死等),多为wait和join引起

6:BLOCK

block状态,由锁竞争引起的阻塞

/*** Created with IntelliJ IDEA.* Description:* User: Hua YY* Date: 2024-09-19* Time: 16:58*/
public class ThreadDemon18 {public static void main(String[] args) throws InterruptedException {Thread t1 = new Thread(()->{for (int i = 0; i < 3; i++) {System.out.println("线程正在运行");try {Thread.sleep(5000);} catch (InterruptedException e) {throw new RuntimeException(e);}}});System.out.println("t1为NEW状态:"+t1.getState());t1.start();//开始执行线程System.out.println("t1是RUNNABLE状态" + t1.getState());t1.join();//main等待t1线程执行完毕         //想要获取WAITING状态把这一行屏蔽掉Thread.sleep(500);//这里是确保让下一句不要那么快执行,正好让 Thread在sleep(1000)的期间获取状态System.out.println("t1是TERMINATED状态"+t1.getState());}
}

 

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

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

相关文章

PyTorch 实现手写数字识别

PyTorch 实现手写数字识别 在本教程中&#xff0c;我们将使用 PyTorch 实现经典的手写数字识别任务。我们将使用 MNIST 数据集&#xff0c;这是一个包含手写数字的图像数据集。我们将介绍如何使用 PyTorch 构建、训练和评估一个简单的卷积神经网络&#xff08;CNN&#xff09;…

【linux】kill命令

kill 命令在 Linux 和类 Unix 系统中用于向进程发送信号&#xff0c;默认情况下是发送 SIGTERM&#xff08;信号 15&#xff09;&#xff0c;请求程序终止运行。如果程序没有响应 SIGTERM 信号&#xff0c;可以使用 SIGKILL&#xff08;信号 9&#xff09;强制终止进程&#xf…

java之斗地主部分功能的实现

今天我们要实现斗地主中发牌和洗牌这两个功能&#xff0c;该如何去实现呢&#xff1f; 1.创建牌类&#xff1a;52张牌每一张牌包含两个属性:牌的大小和牌的花色。 故我们优先创建一个牌的类(Card)&#xff1a;包含大小和花色。 public class Card { //单张牌的大小及类型/…

无人机+自组网:中继通信增强技术详解

无人机与自组网技术的结合&#xff0c;特别是通过中继通信增强技术&#xff0c;为无人机在复杂环境中的通信提供了稳定、高效、可靠的解决方案。以下是对该技术的详细解析&#xff1a; 一、无人机自组网技术概述 无人机自组网技术是一种利用无人机作为节点&#xff0c;通过无…

proteus仿真学习(1)

一&#xff0c;创建工程 一般选择默认模式&#xff0c;不配置pcb文件 可以选用芯片型号也可以不选 不选则从零开始布局&#xff0c;没有初始最小系统。选用则有初始最小系统以及基础的main函数 本次学习使用从零开始&#xff0c;不配置固件 二&#xff0c;上手软件 1.在元件…

6--SpringBootWeb案例(详解)

目录 环境搭建 部门管理 查询部门 接口文档 代码 删除部门 接口文档 代码 新增部门 接口文档 代码 已有前端&#xff0c;根据接口文档完成后端功能的开发 成品如下&#xff1a; 环境搭建 1. 准备数据库表 (dept 、 emp) -- 部门管理 create table dept( id int un…

深度学习自编码器 - 正则自编码器篇

序言 深度学习领域中&#xff0c;自编码器&#xff08; Autoencoder \text{Autoencoder} Autoencoder&#xff09;作为一种无监督学习技术&#xff0c;凭借其独特的结构在数据降维、特征提取、异常检测及数据去噪等方面展现出强大的能力。正则自编码器&#xff0c;作为自编码器…

ES5 在 Web 上的现状

最后一个支持 ES5 的浏览器 IE 11 在 2022 年被微软停止支持&#xff0c;那么今天 Web 上的 ES5 现状如何&#xff1f;在构建生产代码时&#xff0c;Web 开发者的最佳实践是什么&#xff1f; 本文将通过数据来回答这些问题&#xff0c;并基于这些数据为网站开发者和库作者提供一…

Delta Lake如何使用

1. 安装 Java 确保你的系统上安装了 Java 8 或更高版本。可以通过以下命令检查 Java 是否已安装&#xff1a; java -version2. 安装 Apache Spark 下载 Spark&#xff1a; 从 Apache Spark 官方网站 下载适合的版本&#xff0c;建议下载预编译的版本&#xff08;例如&#xf…

如何有效检测住宅IP真伪?

在当今的互联网时代&#xff0c;住宅IP&#xff08;即家庭用户通过宽带服务提供商获得的IP地址&#xff09;在跨境电商、广告投放、网络安全等多个领域扮演着重要角色。然而&#xff0c;随着网络环境的复杂化和欺诈行为的增多&#xff0c;如何有效检测和辨别住宅IP的真伪成为了…

Spring:统一结果私有属性造成的前端无法访问异常报错问题

用户未填写任何评价 1.问题复现 &#xff08;1&#xff09;看一段代码 controller&#xff1a; import lombok.extern.slf4j.Slf4j; import org.ljy.testdemo.common.Result; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.w…

深入解析 SQLSugar:从基础 CRUD 到读写分离与高级特性详解

SQLSugar 使用指南&#xff1a;从入门到进阶及高级特性详解 SQLSugar 是一款功能丰富的 .NET ORM 框架&#xff0c;它支持多种数据库、简洁的 API 和优雅的编程体验。相较于其他 ORM&#xff0c;SQLSugar 提供了很多开发者友好的功能&#xff0c;比如自动创建表结构、灵活的查…

在HTML中添加图片

在HTML中添加图片&#xff0c;你需要使用<img>标签。这个标签用于在网页上嵌入图像。<img>是一个空元素&#xff0c;它只包含属性&#xff0c;并且没有闭合标签。要在<img>标签中指定要显示的图像&#xff0c;你需要使用src&#xff08;source的缩写&#xf…

Centos中关闭swap分区,关闭内存交换

概述&#xff1a; Swap 分区是 Linux 系统中扩展物理内存的一种机制。Swap的主要功能是当全部的RAM被占用并需要更多内存时&#xff0c;用磁盘空间代理RAM内存。Swap对虚拟化技术资源损耗非常大&#xff0c;一般虚拟化是不允许开启交换空间的&#xff0c;如果不关闭Swap&…

【Linux课程学习】make/Makefile:Linux项目自动化构建工具

&#x1f381;个人主页&#xff1a;我们的五年 &#x1f50d;系列专栏&#xff1a;Linux课程学习 &#x1f337;追光的人&#xff0c;终会万丈光芒 &#x1f389;欢迎大家点赞&#x1f44d;评论&#x1f4dd;收藏⭐文章 &#x1f349;一.make/Makefile的理解&#xff1a; …

关于STM32项目面试题02:ADC与DAC篇(输入部分NTC、AV:0-5V、AI:4-20mA和DAC的两个引脚)

博客的风格是&#xff1a;答案一定不能在问题的后面&#xff0c;要自己想、自己背&#xff1b;回答都是最精简、最精简、最精简&#xff0c;可能就几个字&#xff0c;你要自己自信的展开。 面试官01&#xff1a;什么是模数转换/ADC&#xff1f;说说模数转换的流程&#xff1f; …

mysql5.7常用操作命令手册

文章目录 前言一、关闭mysql服务1.mha节点,关闭MHA高可用2.主节点&#xff0c;摘掉vip&#xff0c;停掉mysql服务3.从节点&#xff0c;停掉mysql服务 二、启动mysql1.启动数据库顺序2.主节点&#xff0c;登陆数据库检查主库状态,将主库改成读写状态3.从节点启动配置数据库&…

基于SpringBoot+Vue+MySQL的手机销售管理系统

系统展示 用户前台界面 管理员后台界面 商家后台界面 系统背景 随着智能手机的普及和市场竞争的日益激烈&#xff0c;手机销售行业面临着前所未有的挑战与机遇。传统的手工记录和简单的电子表格管理方式已难以满足现代手机销售业务的需求&#xff0c;销售数据的混乱和管理效率低…

Python基础知识——字典排序(不断补充)

目录 专栏导读代码1&#xff1a;value是多个字符拼接(含拼接符号)(升序)代码2&#xff1a;value是单个值(升序)代码3&#xff1a;按值排序(升序)代码4&#xff1a;按值排序(降序)总结 专栏导读 &#x1f338; 欢迎来到Python办公自动化专栏—Python处理办公问题&#xff0c;解放…

技术成神之路:设计模式(十四)享元模式

介绍 享元模式&#xff08;Flyweight Pattern&#xff09;是一种结构性设计模式&#xff0c;旨在通过共享对象来有效地支持大量细粒度的对象。 1.定义 享元模式通过将对象状态分为内部状态&#xff08;可以共享&#xff09;和外部状态&#xff08;不可共享&#xff09;&#xf…