当前位置: 首页 > news >正文

多线程的创建,复习匿名内部类,Thread的一些方法,以及lambda的变量捕捉,join用法

一、💛 

Java的Thread类表示线程

1.创建类,继承Thread重写run方法

2.创建类,实现Runnable重写run方法

3.可以继承Thread重写run基于匿名内部类

4.实现Runnable重写run基于匿名内部类

5.lamdba表达式表示run方法的内容(推荐)

6。基于Callable(以后学)

7.基于线程池(以后学)

 匿名内部类(不用看定义,看下面用法领悟):正常建类后面大括号,这一步相当于先创建一个子类,但是这个子类是没有名字(匿名),另一方面,这类的创建是在Demo这个类里面。

下面这个写法是3号💛💛

我们要记住一个是,最重要的是写run这个是赋予了线程需要做什么工作。

public  class  Demo {public static void main(String[] args) throws InterruptedException {Thread t=new Thread(){      //匿名内部类,看上面详细解答@Overridepublic void run() {     //子类中重写了run方法,实现了线程要干的工作while(true){System.out.println("hello world");try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}}}};t.start();               //创建了该类的实例,并且是使用那个t这个引用指向。while (true) {System.out.println("love");Thread.sleep(1000);}}}

写法4😃😃

为什么括号不是封死的,因为小括号对应的是Thread构造方法的结束,new Runnable整个一段,都在构造出一个Thread的参数, 创建这个匿名内部类,通过构造方法传给Thread。

public  class  Demo {public static void main(String[] args) throws InterruptedException {Thread t=new Thread(new Runnable (){            //!!!括号不是封死的@Overridepublic void run() {while(true){System.out.println("hello world");try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}}}   ) ;                 //!!!!!看这个小括号t.start();while (true) {System.out.println("love");Thread.sleep(1000);}}}

5.使用lambda(推荐的方法) 表示run方法的内容😗😗 (本质是匿名方法,这样的匿名函数,主要可以作为回调函数使用。——回调函数(合适的时候就干,不合适就选择不干。),不需要程序猿们主动去调动(需要知道函数名,才能被调动,常用场景 1.服务器开发 2.图形界面开发,用户的某个操作,触发回调),而是在合适的时机自动的被调动

Java本身不允许函数脱离类,但是lambda特例,起名叫“函数式接口”(😊必须只有一个方法😊)

类似于Lammbda这样的写法,本质上并没有新增新的语言特性,而是把以往实现的功能,换了一种更简单的方式编写。

public  class  Demo {public static void main(String[] args) throws InterruptedException {Thread t=new Thread(()->{                //也是没有右括号,在下面。while(true){System.out.println("hello world");try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}});t.start();while (true) {System.out.println("love");Thread.sleep(1000);}}}

二、 💚 

Thread就是Java,线程的代言人,系统中一个线程,对应Java中一个Thread对象

public  class  Demo {public static void main(String[] args) throws InterruptedException {Thread t=new Thread(()->{while(true){System.out.println("hello world");try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}},"myThread");           //给这个进程起名字t.start();while (true) {System.out.println("love");Thread.sleep(1000);}}}

Thread常见ID。线程的身份标识(JVM,给设定了一个标识)

一个线程可以存好几个身份标记:

1.JVM有一个身份标记

2.pthread库(系统给程序猿提供的操作线程的API,也有一个线程的身份标识)

3.内核里面,针对线程的PCB还有身份标识

Thread常见属性

id.           getId()                            

name.     getname()

状态。     getState()           java中线程的状态和操作系统的有一定差异。

优先级     getPriority          设置获取优先级的作用不是很大,线程的调度,主要还是系统内核负责~系统的调度速度更快。

是否是后台进程   isDaemon()          

后台进程/守护进程,后台进程不影响进程结束,(创建的线程默认是前端线程)前台进程会影响到进程结束,如果前台进程没执行完,进程是不会结束的。

一个进程的所有前台线程,都执行完退出了,那么即使存在后端线程没有执行完毕,也会随着进程一起退出

setDaemon(true)   把某一个进程,设置为后端进程,这样前端线程结束,后面的也结束了

public  class  Demo {public static void main(String[] args) throws InterruptedException {int n =0;Thread t=new Thread(()->{int m =0;while(m<9){System.out.println("hello world");m++;try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}},"myThread");t.setDaemon(true);             //设置为后端线程t.start();while (n<3) {           // 打印完事走完全部就结束了,所以一定会有这三个System.out.println("love");    n++;Thread.sleep(1000); }}}

是否存活 isAlive

Thread对象,对应的线程(在系统内核中)是否存活。

Thread对象,并不是和系统中的线程完全一样(同生共死)的。

一般的Thread对象,先创建好,~手动调用start ,内核才真正创造出线程

消亡的时候,

可能对象,先结束了生命周期(没有引用指向这个对象)

也有可能Thread对象还在,内核中的线程把run执行完成了,就结束了。

对象的整个生命周期大致可以分为7个阶段:

创建阶段、应用阶段、不可视阶段、不可到达阶段、可收集阶段、终结阶段、与释放阶段(了解就好)

重要方法start():真正创造出线程->调用系统API完成线程创建工作(本身是一瞬间完成的,相当于是传话的小弟,“你造个线程出来😈”,调用API之后代码立刻执行start之后的逻辑

操作系统=内核+配套的程序

一个系统最核心的功能:

1.对下管理好各种硬件设备

2.对上,给各种程序提供稳定的运行环境

操作系统的内核(应用程序):

创建线程,非常核心的功能,系统API,系统调用

一般情况应用,不可进入内核操作,不可进入内核的程序成为“用户态”

如果一些应用程序,能够进入后台,直接操作内核里面的一些数据结构,程序是出于“内核态”这样的程序还叫做驱动程序


、💙  

Thread的方法💙 

(一个线程的run方法执行完毕,就算终止了。此时的终止此处线程,就是要想办法让run尽快执行完毕(正常不会出现run没执行完毕,突然就没了的情况)

(sleep相当于是停一会,不是说停止了)

1.程序猿们手动设置标志位,如

public static voolean isQuit=false;(写成成员变量,不会触发变量捕捉,而是内部类来访问成员变量, 看下面这个图,代码在后面,执行完isQuit=true; 线程就终止了,同时main也走完了。

public  class  Demo {public static boolean isQuit=false;public static void main(String[] args) throws InterruptedException {int n =0;Thread t=new Thread(()->{int m =0;while(!isQuit){System.out.println("hello world");try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}},"myThread");t.start();while (n<3) {System.out.println("love");n++;Thread.sleep(1000);}isQuit=true;          //手动终止}}

但是我们来看下面这个图,为什么我这样放进方法里面不可以呢?——这就源于我们lambda表达式的变量捕捉机制​​​​​​​~

lambda可以捕获外界变量,这样lambda表达式执行的时机是更靠后的,这就导致,后续真正执行lambda时候,局部变量isQuit是否可能已经被销毁了呢?

这种情况是客观存在的,让lambda去访问一个已经被销毁的变量,很明显是不合适的,lambda引入了变量捕获这样的机制~,lambda去访问一个已经被销毁的变量,但明显是不合适的,lambda引入了变量捕获这样的机制~,lambda内部看起来是直接访问外部的变量,其实本质是把外部变量给复制了一份,到lambda里面(这样就可以解决刚才的生命周期问题了)(但是捕获变量有限制的,要求是be final(如同final,就是一个变量,我们后续没有修改他的操作)  or effectively final(事实上的最终值 final修饰)

2.直接用Thread 类,给我们提供了现成标志位,不用手动, 🐶

while(!Thread.currentThread().isInterrupted())

Thread.currentThread():的含义获取当前线程的对象Thread,提供静态方法,currentThread在哪个线程调动这个方法,就能够获取到哪个线程的引用(相当于就是t,但是不可以写t,写t是报错的)

isInterrupted()

对象内部,提供了一个标志位(boolean类型的)

true:结束

false:不结束

我们看上面的图能发现,为啥还会有异常呢?🐹,原因就是一个线程kennel正在运行,也可能处于sleep状态,如果线程sleep的过程中,是否应该把他唤醒你?

当然了,肯定要把他唤醒,但是sleep在唤醒的同时也会自动清除前面设置的标志位,给程序猿们留下操作空间,此时要是想让线程结束,则catch之后加一个break;

sleep唤醒之后,程序猿们一般有以下几种操作方式:

1.立即停下来,立即结束线程

2.忽略终止请求,继续循环(不写break)

3.继续做点别的事情,过一会再结束线程(catch之后执行别的逻辑,最后break;)

 

public  class  Demo {public static void main(String[] args) throws InterruptedException {int n =0;Thread t= new Thread(()->{int m =0;while(!Thread.currentThread().isInterrupted()){System.out.println("hello world");try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();break;}}},"myThread");t.start();while (n<3) {System.out.println("love");n++;Thread.sleep(1000);}t.interrupt();}}

四、💗 

等待线程——join

多个线程是并发执行的,具体的执行过程,都是由操作系统复制调度的!!!,操作系统的调度线程“随机的”(当然,是我们无法确定他的先后顺序)

等待线程就是一种规划线程结束顺序的手段~ A,B两个线程,希望B先结束,A后结束,此时就可以,让A线程调用B.join方法(去等待B)

此时B线程还没结束完,A线程就会进入阻塞状态,相当于给B留下了空间,B执行完毕之后,A再从阻塞状态中恢复回来,并且继续往后执行。,如果A执行到B.join的时候,B已经执行完,那么A就不用阻塞了,直接往下执行即可,如下图,他是等待,先把t这个线程走完了,再去走下面的main.

​​​​​​​

阻塞->该代码暂时不继续执行(该进程暂时不去cpu参与调度)sleep也能让该线程阻塞,但是是有时间限制的

join是死等,知道你完事,不然他不会开始(不推荐) 产生一个新的join(里面填写时间)最大等待时间。只要我时间到了,不管你来不来,我都走了(更推荐使用,这种时间版本,留有余地。)

可以被interrupt唤醒的等待操作:

1.join

2.sleep

3.wait

 需要的自己拿着用呗

public  class  Demo {public static void main(String[] args) throws InterruptedException {int n =0;Thread t= new Thread(()->{int m =0;while(m<5){System.out.println("hello world");m++;try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}},"myThread");t.start();t.join(3000);while (n<3) {System.out.println("love");n++;Thread.sleep(1000);}}}

相关文章:

多线程的创建,复习匿名内部类,Thread的一些方法,以及lambda的变量捕捉,join用法

一、&#x1f49b; Java的Thread类表示线程 1.创建类&#xff0c;继承Thread重写run方法 2.创建类&#xff0c;实现Runnable重写run方法 3.可以继承Thread重写run基于匿名内部类 4.实现Runnable重写run基于匿名内部类 5.lamdba表达式表示run方法的内容&#xff08;推荐&#x…...

瑞吉外卖系统05

哈喽&#xff01;大家好&#xff0c;我是旷世奇才李先生 文章持续更新&#xff0c;可以微信搜索【小奇JAVA面试】第一时间阅读&#xff0c;回复【资料】更有我为大家准备的福利哟&#xff0c;回复【项目】获取我为大家准备的项目 最近打算把我手里之前做的项目分享给大家&#…...

D455+VINS-Fusion+surfelmapping 稠密建图(三)

继续&#xff0c;由surfelmapping建立的点云生成octomap八叉树栅格地图 一、安装OctomapServer 建图包 安装插件 sudo apt-get install ros-melodic-octomap-ros sudo apt-get install ros-melodic-octomap-msgs sudo apt-get install ros-melodic-octomap-server sudo apt-…...

rv1109/1126 rknn 模型部署过程

rv1109/1126是瑞芯微出的嵌入式AI芯片&#xff0c;带有npu, 可以用于嵌入式人工智能应用。算法工程师训练出的算法要部署到芯片上&#xff0c;需要经过模型转换和量化&#xff0c;下面记录一下整个过程。 量化环境 模型量化需要安装rk的工具包&#xff1a; rockchip-linux/rk…...

Android平台一对一音视频通话方案对比:WebRTC VS RTMP VS RTSP

一对一音视频通话使用场景 一对一音视频通话都需要稳定、清晰和流畅&#xff0c;以确保良好的用户体验&#xff0c;常用的使用场景如下&#xff1a; 社交应用&#xff1a;社交应用是一种常见的使用场景&#xff0c;用户可以通过音视频通话进行面对面的交流&#xff1b;在线教…...

--binlog-row-event-max-size

--binlog-row-event-max-size MySQL中用于控制rows格式的Binlog&#xff0c;binlog以chunk的方式存储&#xff0c;每个chunk的大小由binlog-row-event-max-size 进行控制&#xff1b; 如果event比较大的时候可以调大这个值&#xff1b;&#xff1b;改值必须是256的倍数&#…...

Jmeter命令行运行实例讲解

1. 简介 使用非 GUI 模式&#xff0c;即命令行模式运行 JMeter 测试脚本能够大大缩减所需要的系统资 本文介绍windows下以命令行模式运行的方法。 1.1. 命令介绍 jmeter -n -t <testplan filename> -l <listener filename> 示例&#xff1a; jmeter -n -t test…...

pl/sql函数如何返回多行数据?在线等......

​编辑csm8109022010-01-27 09:59:18 这个问题我以前问过类似的&#xff0c;但一直没得到如意的答案&#xff01;在oracle 里soctt的用户下的emp表&#xff0c;比如写一个函数&#xff0c;传入的参数为部门编号&#xff0c;然后返回所有该部门人员信息的函数。要用到游标&…...

Ubuntu Find命令详解

一、Find命令简介 Ubuntu的Find命令是一种常用的终端指令&#xff0c;用于在文件系统中查找符合条件的文件和目录。该命令的语法格式如下&#xff1a; find [PATH] [OPTION] [EXPRESSION]其中&#xff0c;PATH表示待查找的目录&#xff0c;OPTION为选项参数&#xff0c;EXPRES…...

ADS Momentum学习笔记

ADS Momentum的简介 ADS Layout界面仿真采用的方法主要是Momentum&#xff08;矩量法&#xff09;。 Momentum的特点 Momentum是高级设计系统&#xff08;ADS&#xff09;的重要组成部分&#xff0c;它提供了设计现代通信系统的电磁仿真。它可以用来计算一般平面电路的S参数…...

解决Vue3 使用Element-Plus导航刷新active高亮消失

解决Vue3 使用Element-Plus导航刷新后active高亮消失的问题 启用路由模式会在激活导航时以 index 作为 path 进行路由跳转 使用 default-active 来设置加载时的激活项。 接下来打印一下选中项index和index路径&#xff0c; 刷新也是没有任何问题的&#xff0c;active不会消失…...

K8S系列文章之 一键部署K8S环境

部署的原理是基于自动化部署工具 Ansible 实现的&#xff0c;需要提前安装Ansible 并配置下主机节点环境 1. 安装 Ansible 首先ansible基于python2.X 环境&#xff0c;默认centos都已经安装好了python2环境 // 最好更新下库 // yum update yum install -y epel-release yum i…...

Spring Boot、Spring Cloud、Spring Alibaba 版本对照关系及稳定兼容版本

Spring Boot、Spring Cloud、Spring Alibaba 版本对照关系及稳定兼容版本 引言 在 Java 生态系统中&#xff0c;Spring Boot、Spring Cloud 和 Spring Alibaba 是非常流行的框架&#xff0c;它们提供了丰富的功能和优雅的解决方案。然而&#xff0c;随着不断的发展和更新&…...

虫情监测仪介绍—技术原理、功能优势是什么?

KH-CQPest虫情监测仪是做好虫情监测的重要设备&#xff0c;利用虫情监测仪能够对农业大田、智慧温室、林业等场景的害虫分布情况及害虫种类进行监测&#xff0c;协助人们制定合理的防治措施。 1.技术原理&#xff1a; KH-CQPest虫情监测仪采用光学诱虫原理&#xff0c;配合传感…...

HTML5 Canvas和Svg:哪个简单且好用?

HTML5 Canvas 和 SVG 都是基于标准的 HTML5 技术&#xff0c;可用于创建令人惊叹的图形和视觉体验。 首先&#xff0c;让我们花几句话介绍HTML5 Canvas和SVG。 什么是Canvas? Canvas&#xff08;通过 标签使用&#xff09;是一个 HTML 元素&#xff0c;用于在用户计算机屏幕…...

ChatGPT在社交媒体聊天和评论分析中的应用如何?

ChatGPT在社交媒体聊天和评论分析中具有广泛的应用前景&#xff0c;可以帮助企业、个人和社会从多个角度更好地理解用户观点、趋势和情感。以下是详细的讨论&#xff1a; **1. 舆情分析与趋势预测&#xff1a;** ChatGPT可以用于分析社交媒体上的评论、帖子和消息&#xff0c;…...

DoIP学习笔记系列:(四)用CAPL脚本读取DID的关键点

文章目录 1. 如何在CAPL中读取DID?1.1 避坑如何新建CAPL工程,在此不再赘述,本章主要分享一下如何在CAPL中调用DoIP接口、diag接口进行DoIP和诊断的测试。 1. 如何在CAPL中读取DID? 通常在实际项目中,会有很多DID,各种版本号、各种观测量,如果手动点,显然很麻烦,如果要…...

chrome插件开发实例06-定制自己的Chrome DevTools调试工具

目录 Chrome DevTools 调试工具 演示 ​编辑 源码 devtools.html devtools.js panel.html panel.js...

安卓读取,添加,更新,删除联系人,读取短信

目录 读取联系人 添加联系人 更新联系人 删除联系人 读取短信 读取联系人 安卓可以通过contentResolver来读取联系人表&#xff0c;联系人表的Uri信息是&#xff1a;content://com.android.contacts/data/phones 从而输出联系人信息&#xff0c; 需要相关权限&#xff1a…...

Practices6|69. x 的平方根、(哈希表)205. 同构字符串、(哈希表)1002. 查找共用字符

69. x 的平方根 1.题目&#xff1a; 给你一个非负整数 x &#xff0c;计算并返回 x 的 算术平方根 。 由于返回类型是整数&#xff0c;结果只保留 整数部分 &#xff0c;小数部分将被 舍去 。 注意&#xff1a;不允许使用任何内置指数函数和算符&#xff0c;例如 pow(x, 0.…...

MPNet:旋转机械轻量化故障诊断模型详解python代码复现

目录 一、问题背景与挑战 二、MPNet核心架构 2.1 多分支特征融合模块(MBFM) 2.2 残差注意力金字塔模块(RAPM) 2.2.1 空间金字塔注意力(SPA) 2.2.2 金字塔残差块(PRBlock) 2.3 分类器设计 三、关键技术突破 3.1 多尺度特征融合 3.2 轻量化设计策略 3.3 抗噪声…...

Java 语言特性(面试系列2)

一、SQL 基础 1. 复杂查询 &#xff08;1&#xff09;连接查询&#xff08;JOIN&#xff09; 内连接&#xff08;INNER JOIN&#xff09;&#xff1a;返回两表匹配的记录。 SELECT e.name, d.dept_name FROM employees e INNER JOIN departments d ON e.dept_id d.dept_id; 左…...

C++_核心编程_多态案例二-制作饮品

#include <iostream> #include <string> using namespace std;/*制作饮品的大致流程为&#xff1a;煮水 - 冲泡 - 倒入杯中 - 加入辅料 利用多态技术实现本案例&#xff0c;提供抽象制作饮品基类&#xff0c;提供子类制作咖啡和茶叶*//*基类*/ class AbstractDr…...

RocketMQ延迟消息机制

两种延迟消息 RocketMQ中提供了两种延迟消息机制 指定固定的延迟级别 通过在Message中设定一个MessageDelayLevel参数&#xff0c;对应18个预设的延迟级别指定时间点的延迟级别 通过在Message中设定一个DeliverTimeMS指定一个Long类型表示的具体时间点。到了时间点后&#xf…...

【RockeMQ】第2节|RocketMQ快速实战以及核⼼概念详解(二)

升级Dledger高可用集群 一、主从架构的不足与Dledger的定位 主从架构缺陷 数据备份依赖Slave节点&#xff0c;但无自动故障转移能力&#xff0c;Master宕机后需人工切换&#xff0c;期间消息可能无法读取。Slave仅存储数据&#xff0c;无法主动升级为Master响应请求&#xff…...

JUC笔记(上)-复习 涉及死锁 volatile synchronized CAS 原子操作

一、上下文切换 即使单核CPU也可以进行多线程执行代码&#xff0c;CPU会给每个线程分配CPU时间片来实现这个机制。时间片非常短&#xff0c;所以CPU会不断地切换线程执行&#xff0c;从而让我们感觉多个线程是同时执行的。时间片一般是十几毫秒(ms)。通过时间片分配算法执行。…...

云原生安全实战:API网关Kong的鉴权与限流详解

&#x1f525;「炎码工坊」技术弹药已装填&#xff01; 点击关注 → 解锁工业级干货【工具实测|项目避坑|源码燃烧指南】 一、基础概念 1. API网关&#xff08;API Gateway&#xff09; API网关是微服务架构中的核心组件&#xff0c;负责统一管理所有API的流量入口。它像一座…...

jdbc查询mysql数据库时,出现id顺序错误的情况

我在repository中的查询语句如下所示&#xff0c;即传入一个List<intager>的数据&#xff0c;返回这些id的问题列表。但是由于数据库查询时ID列表的顺序与预期不一致&#xff0c;会导致返回的id是从小到大排列的&#xff0c;但我不希望这样。 Query("SELECT NEW com…...

OCR MLLM Evaluation

为什么需要评测体系&#xff1f;——背景与矛盾 ​​ 能干的事&#xff1a;​​ 看清楚发票、身份证上的字&#xff08;准确率>90%&#xff09;&#xff0c;速度飞快&#xff08;眨眼间完成&#xff09;。​​干不了的事&#xff1a;​​ 碰到复杂表格&#xff08;合并单元…...

WebRTC调研

WebRTC是什么&#xff0c;为什么&#xff0c;如何使用 WebRTC有什么优势 WebRTC Architecture Amazon KVS WebRTC 其它厂商WebRTC 海康门禁WebRTC 海康门禁其他界面整理 威视通WebRTC 局域网 Google浏览器 Microsoft Edge 公网 RTSP RTMP NVR ONVIF SIP SRT WebRTC协…...