多线程的学习第二篇

previewfile_28144258300213

多线程

线程是为了解决并发编程引入的机制.
线程相比于进程来说,更轻量
~~ 更轻量的体现:

  • 创建线程比创建进程,开销更小
  • 销毁线程比销毁进程,开销更小
  • 调度线程比调度进程,开销更小

进程是包含线程的.
同一个进程里的若干线程之间,共享着内存资源和文件描述符表

每个线程被独立调度执行.每个线程都有自己的状态/优先级/上下文/记账信息

进程是操作系统资源分配的基本单位
线程是操作系统调度执行的基本单位


Thread类 ~~ 五种创建线程的写法

1.继承Thread,重写run
2.实现Runnable,重写run
3.使用匿名内部类,继承Thread
4.使用匿名内部类,实现 Runnable
5.使用lambda表达式

使用了不同的方式来描述, Thread里的任务是什么.
上述办法,只是语法规则不同,本质上都是一样的方式.
~~ 这些方法创建出来的线程,都是一样的.

对Thread的run方法和start方法的区别
run ~~ 描述了线程要做的工作.
start ~~ 真的在操作系统内核里弄了个线程,并且让新线程调用run方法.


Thread的用法

Thread 的常见构造方法

方法说明
Thread()创建线程对象
Thread(Runnable target)使用 Runnable 对象创建线程对象
Thread(String name)创建线程对象,并命名
Thread(Runnable target, String name)使用 Runnable 对象创建线程对象,并命名

Thread(Runnable target, String name)
Thread(String name)
这2个方法的参数String name
=> 给线程起个名字 ~~ 为了方便调试
线程默认的名字,叫做thread-0之类的…
thread-1, 2, 3
为了加深印象,写个线程名字为myThread的代码,通过 JConsole 观察线程的名字

public class ThreadDemo6 {public static void main(String[] args) {Thread t = new Thread(new Runnable() {@Overridepublic void run() {while(true){System.out.println("hello");}}},"myThread");t.start();}
}

image-20230920004942382

这图中没有主线程的存在 ~~ 主线程执行完了start之后,紧接着就结束了main方法.
对于主线程来说, main方法完了,自己也就没了.
myThread线程也是如此,run方法执行完了,此时线程也就没了.
图示:
image-20230920010312996

两个线程在微观上,可能是并行(两个核心),也可能是并发的(一个核心)
宏观上感知不到(应用程序这里),咱们看到的始终是随机执行,抢占式调度…
操作系统决定到底怎么使用CPU, 我们是不知道的.

Thread的几个常见属性

属性属性
IDgetId()
名称getName()
状态getState()
优先级getPriority()
是否后台线程isDaemon()
是否存活isAlive()
是否被中断isInterrupted()

getId(): 获取到线程的ID, ID 是线程的唯一标识,不同线程不会重复
getName(): 获取到构造方法里的名字
getState(): 获取到线程状态, 状态表示线程当前所处的一个情况(Java里线程的状态要比操作系统原生的状态更丰富一些)
getPriority(): 优先级,这个不仅可以获取,还可以进行设置,优先级高的线程理论上来说更容易被调度到 ,但是呢,实际上起不到什么作用!!!
isDaemon(): 是否是“守护线程”,也可以叫做是“后台线程” ~~ 相对应的还存在“前台线程”这个概念.
~~ 玩手机的时候,手机上一般都会运行多个APP,在运行多个APP的时候,你打开微信,来聊天,此时微信就处在‘’前台‘’的状态.然后,你想打游戏,就切到王者荣耀的游戏界面.这时,微信就跑到了‘’后台‘’.
前台线程: 会阻止进程结束, 前台线程的工作没做完, 进程是不会结束的
后台线程: 不会阻止进程结束, 后台线程工作没做完, 进程也是可以结束的
代码里手动创建的线程,默认都是前台线程,包括 main 默认也是前台的.
其他的 JVM 自带的线程都是后台的
~~ 也可以使用 setDaemon 设置成后台线程.
是“后台线程”,就是‘’守护线程‘’.

注:要把线程是否是后台,和线程调度切换,区分开,两者不是一回事.
线程的后台前台,只是取决于你调用的setDaemon这个方法做了什么…
image-20230920132218590

isAlive(): 在真正调用start之前,调用t.isAlive 就是 false.调用start之后, isAlive就是 true.
在真正调用start之前,调用t.isAlive 就是 false.调用start之后, isAlive就是 true.
~~ 另外,如果内核里线程把 run千完了,此时线程销毁, pcb随之释放,
但是 Thread t这个对象还不一定被释放的,此时isAlive 也是 false.

image-20230920184520089

Thread t这个对象还不一定被释放的,此时isAlive 也是 false的例子:
image-20230920191341931

如果t的run还没跑, isAlive 就是false
如果t的run正在跑, isAlive 就是true
如果t的run跑完了, isAlive 就是false

时刻牢记!!线程之间是并发执行的,并且是抢占式调度的.

image-20230920195527226

线程调度,就好比,顾客们去餐馆吃饭一样.
如果把CPU 想象成餐馆,每个线程就是来餐馆吃饭的人
假设ABCD这四个人是天天来的常客 工
但你无法确定,今天来的这四个人的顺序是ABCD,还是DCBA,还是BADC……
由于每个人的行为之间都是独立的.A这个来的时间和BCD是没关系的.
即使假设,按照ABCD顺序来了.如果这四个人来的时间差很多,是一个接一个来的,此时也无法保证,上菜的顺序也是ABCD……. => 充满了完全不可预期的因素

以前写代码,只要读懂代码的顺序,就是固定按照从上到下的顺序来执行的…
但是现在不是了,理解多线程代码,要考虑无数种顺序.

中断一个线程

中断的意思是,不是让线程立即就停止,而是通知线程,你应该要停止了.
是否真的停止,取决于线程这里具体的代码写法.
例子: 暑假在家的时候,你正在打王者,突然,你妈喊你下楼去买包盐,
你的选择如下:
1.放下游戏,立即就去.
2.打完这把,再去,稍后处理.
3.假装没听见,就完全不处理.
不同的选择,就对应不同的结果

停止线程的方式

目前常见的有以下两种方式:

1.使用标志位来控制线程是否要停止.

示例代码

public class ThreadDemo8 {public static boolean flag = true;public static void main(String[] args) {Thread t = new Thread(()->{while (flag){System.out.println("hello thread");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}});t.start();try {Thread.sleep(3000);} catch (InterruptedException e) {throw new RuntimeException(e);}//在主线程里就可以随时通过 flag变量的取值,来操作t线程是否结束.flag = false;}
}

运行结果

image-20230920214459036

这个代码之所以能够起到,修改flag, t 线程就结束
=> 完全取决于t 线程内部的代码.代码里通过flag控制循环.
这个线程是否要结束,啥时候结束都是线程内部自己代码来决定的.
缺陷
自定义变量这种方式不能及时响应.尤其是在sleep 休眠的时间比较久的时候

2.使用Thread自带的标志位进行判定

~~ 它是可以唤醒上面的这个sleep这样的方法的.
示例代码

public class ThreadDemo9 {public static void main(String[] args) throws InterruptedException {Thread t =new Thread(()->{while (!Thread.currentThread().isInterrupted()){System.out.println("hello thread");try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}});t.start();Thread.sleep(3000);t.interrupt();}
}

!Thread.currentThread().isInterrupted()
它是Thread类的静态方法,通过这个方法可以获取到当前线程.
哪个线程调用的这个方法,就是得到哪个线程的对象引用. ~~ 很类似于this
在博主所写的上述代码中,是在t.run中被调用的.此处获取的线程就是t线程.

isInterrupted() ~~ 前面加了个‘!,表示逻辑取反.
为true表示被终止.
为false表示未被终止.(应该要继续走)

t.interrupt(); => 终止 t 线程

​ 注: isInterrupted() => 这个方法背后,就相当于是判定一个boolean变量
t.interrupt() => 就是在设置这个 boolean 变量

​ main 线程调用 t.interrupt() 相当于main通知 t 线程你要终止了.

方法说明
public void interrupt()中断对象关联的线程,如果线程正在阻塞,则以异常方式通知, 否则设置标志位
public static boolean interrupted()判断当前线程的中断标志位是否设置,调用后清除标志位
public boolean isInterrupted()判断对象关联的线程的标志位是否设置,调用后不清除标志位

image-20230920234340825

image-20230921000821986

为啥 sleep要清除标志位?
唤醒之后,线程到底要终止,还是不要到底是立即终止还是稍后,就把选择权
交给程序猿自己了!!!

等待一个线程

~~ join()
线程是一个随机调度的过程.
等待线程,做的事情,就是在控制两个线程的结束顺序.
示例代码

public class ThreadDemo10 {public static void main(String[] args) {Thread t = new Thread(()->{for (int i = 0; i < 3; i++) {System.out.println("hello thread");try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}});t.start();System.out.println("join 之前");try {t.join();} catch (InterruptedException e) {e.printStackTrace();}System.out.println("join 之后");}
}

运行结果

image-20230921004505244

画图对代码进行解释:

image-20230921004425415

主线程,等待 t 线程彻底执行完毕之后,才继续往下执行了

假设开始执行join的时候, t 线程已经结束了,此时join 会咋样?
如果是执行join的时候, t 线程已经结束了join不会阻塞,就会立即返回 => 保证线程的结束顺序

方法说明理解
public void join()等待线程结束无参数版本,“死等”,不见不散
public void join(long millis)等待线程结束,最多等 millis 毫秒指定一个超时时间(最大等待时间) ~~ 这种操作方式是更常见的 ~~ 死等很容易出问题
public void join(long millis, int nanos)同理,但可以更高精度不做注释

知识扩展

多线程是实现并发编程的基础方式.比较接近系统底层,使用起来不太友好
为了简化并发编程,也引入了很多更方便,更不容易出错的写法
比如,erlang(编程语言),引入actor 模型.
go,引入了csp模型
js, 使用回调的方式 => async await
python => async await
……

                                            |

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

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

相关文章

ORB-SLAM2_RGBD_DENSE_MAP编译、问题解决、离线加载TUM数据和在线加载D435i相机数据生成稠密地图

文章目录 0 引言1 安装依赖1.1 其他库安装1.2 pcl库安装 2 编译ORB-SLAM2_RGBD_DENSE_MAP2.1 build.sh2.2 build_ros.sh 3 运行ORB-SLAM2_RGBD_DENSE_MAP3.1 build.sh编译版本3.2 build_ros.sh编译版本 0 引言 ORB-SLAM2_RGBD_DENSE_MAP是基于ORB-SLAM2框架的一种RGB-D稠密地图…

uniapp Echart X轴Y轴文字被遮挡怎么办,或未能铺满整个容器

有时候布局太小&#xff0c;使用echarts&#xff0c;x轴y轴文字容易被遮挡&#xff0c;怎么解决这个问题呢&#xff0c;或者是未能铺满整个容器。 方法1&#xff1a; 直接设置 containLabel 字段 options: { grid: { containLabel: true, },} 方法2: 间接设置&#xff0c;但是…

Kotlin协程CoroutineScope异步async取消cancel等待await的任务

Kotlin协程CoroutineScope异步async取消cancel等待await的任务 import kotlinx.coroutines.*fun main(args: Array<String>) {runBlocking {val mScope CoroutineScope(Dispatchers.IO).async {println("->")delay(999999)println("<-")"…

Jenkins结合Gitlab,实现镜像构建及推送

docker-compose jenkins的docker-compose目录为为/home/jenkins&#xff0c;这个后面写脚本的时候需要对应上 version: 3 services:docker_jenkins:restart: alwaysimage: jenkins/jenkins:ltscontainer_name: docker_jenkinsprivileged: true ports:- 8080:8080- 50000:5000…

【自学开发之旅】Flask-前后端联调-异常标准化返回(六)

注册联调&#xff1a; 前端修改&#xff1a; 1.修改请求向后端的url地址 文件&#xff1a;env.development修改成VITE_API_TARGET_URL http://127.0.0.1:9000/v1 登录&#xff1a;token验证 校验forms/user.py from werkzeug.security import check_password_hash# 登录校验…

Ubuntu下安装Clion

前言 CLion 是一款由 JetBrains 开发的 C 集成开发环境&#xff08;IDE&#xff09;&#xff0c;它拥有许多强大的功能&#xff0c;如代码自动完成、调试器、版本控制等等。CLion本身是收费软件&#xff0c;但如果是学生的话可以申请免费使用。 测试安装环境&#xff1a;Ubunt…

2614. 对角线上的质数-c语言解法

给你一个下标从 0 开始的二维整数数组 nums 。 返回位于 nums 至少一条 对角线 上的最大 质数 。如果任一对角线上均不存在质数&#xff0c;返回 0 。 注意&#xff1a; 如果某个整数大于 1 &#xff0c;且不存在除 1 和自身之外的正整数因子&#xff0c;则认为该整数是一个…

iOS蓝牙 Connection Parameters 关键参数说明

1. 先贴苹果文档 《 Accessory Design Guidelines for Apple Devices 》 2. 几个关键词 connection Event Interval 事件间隔&#xff0c;为1.25ms的倍数。可以简单理解为,是两个连接着的蓝牙设备发送“心跳包”的时间间隔&#xff1b; 范围是 6 ~ 3200&#xff0c;即 7.5…

【ArcGIS】土地利用变化分析详解(栅格篇)

土地利用变化分析详解-栅格篇 土地利用类型分类1 统计不同土地利用类型的面积/占比1.1 操作步骤 2 统计不同区域各类土地利用类型的面积2.1 操作步骤 3 土地利用变化转移矩阵3.1 研究思路3.2 操作步骤 4 分析不同时期土地利用类型及属性变化4.1 研究思路4.2 操作步骤 参考 土地…

建不同锁对象对同表同数据加锁会怎样?

建不同锁对象对同表同数据加锁会怎样&#xff1f; 同事突然问我这个问题&#xff0c;这种东西动手测一下&#xff0c;两分钟的事儿。验证下自己心中所想。 建俩锁对象~ 代码 打断点 执行&#xff1a; 能动手就敲一下&#xff0c;懒得想&#xff0c;懒得记~ 推荐阅读&#xff1a…

ETLCloud助力富勒TMS实现物流数仓同步

富勒TMS提供了多种运输管理业务的解决方案&#xff0c;极大的方便了企业对物流的管理和人力输出&#xff0c;同时提供了大量的API接口&#xff0c;供用户做数据集成和数仓同步。 通过富勒TMS中心&#xff0c;第三方开发者和商家可实现以下功能&#xff1a; MS系统数据同步&…

【QT】day4

闹钟 头文件&#xff1a; #ifndef WIDGET_H #define WIDGET_H#include <QWidget> #include <QDebug> #include <QMouseEvent> //鼠标时间 #include <QPaintEvent> //绘制时间 #include <QPainter> //画家时间 #include <QPixmap> //图…

Python实现MYSQL蜜罐

1 LOAD DATA INFILE介绍 首先开启一个Mysql&#xff0c;看一下mysql是如何读取主机文件的。 1.1 linux搭建mysql 1&#xff09;docker运行mysql 2&#xff09;启动Mysql docker run -itd…

Android Studio插件版本与Gradle 版本对应关系

关于作者&#xff1a;CSDN内容合伙人、技术专家&#xff0c; 从零开始做日活千万级APP。 专注于分享各领域原创系列文章 &#xff0c;擅长java后端、移动开发、商业变现、人工智能等&#xff0c;希望大家多多支持。 目录 一、导读二、概览三、Gradle各版本对应关系3.1 Gradle 版…

【C++】STL详解(六)—— list的模拟实现

​ ​&#x1f4dd;个人主页&#xff1a;Sherry的成长之路 &#x1f3e0;学习社区&#xff1a;Sherry的成长之路&#xff08;个人社区&#xff09; &#x1f4d6;专栏链接&#xff1a;C学习 &#x1f3af;长路漫漫浩浩&#xff0c;万事皆有期待 上一篇博客&#xff1a;【C】STL…

移动测试之语音识别功能如何测试?

移动测试之语音识别功能如何测试&#xff1f; 要知道语音识别功能如何测试&#xff0c;我们先了解智能产品语音交互流程&#xff1a; 所以&#xff0c;要进行测试的话&#xff0c;我们需要从以下几个维度来准备测试点&#xff1a; 基础功能测试&#xff1a; 1、声纹的录入&…

【Java 基础篇】Java Condition 接口详解

Java 提供了一种更灵活和高级的线程协作机制&#xff0c;通过 Condition 接口的使用&#xff0c;你可以更精细地控制线程的等待和唤醒&#xff0c;实现更复杂的线程同步和通信。本文将详细介绍 Java 的 Condition 接口&#xff0c;包括它的基本概念、常见用法以及注意事项。 什…

MyBatis 篇

目录 1、什么是MyBatis 2、说说MyBatis的优点和缺点 3、#{}和${}的区别是什么&#xff1f; 4、当实体类中的属性名和表中的字段名不一样 &#xff0c;怎么办 &#xff1f; 5、Mybatis是如何进行分页的&#xff1f;分页插件的原理是什么&#xff1f; 6、Mybatis是否支…

【大数据之Kafka】十五、Kafka-Kraft模式

1 Kafka-Kraft架构 左图为 Kafka 现有架构&#xff0c;元数据在 zookeeper 中&#xff0c;运行时动态选举 controller&#xff0c;由controller 进行 Kafka 集群管理。   右图为 kraft 模式架构&#xff08;实验性&#xff09;&#xff0c;不再依赖 zookeeper 集群&#xff0…

mysql 锁总结

redo log 是事务持久性的保证 undo log 是事务原子性的保证 锁机制 是事务隔离性的保证 MySQL的自动加锁依赖于数据库的事务机制。当事务对某个数据行进行更新操作时&#xff0c;MySQL就会自动给该行加上排他锁&#xff0c;防止其他事务同时对其进行修改。同时&#xff0c;MySQ…