多线程之Thread 类的基本用法
创始人
2025-05-29 18:21:28
0

大家好,今天为大家带来Thread类的基本方法,咱们接着上期继续讲

目录

                                            🎉 1.线程中断

                              '🎉 2.线程等待

                  🎉3.线程休眠

         🎉4.获取线程实例

🎉5.线程的状态


1.线程中断

上一期说的is Interrupted()就是说线程被中断的事情

线程是否被中断取决于线程 的入口方法是否已经执行完毕

进行线程中断只有一个办法:让线程的入口方法执行完毕(要么return,要么抛异常)

1.给线程设定一个结束标志位

上代码

public class ThreadDemo1 {public static boolean isQuit=false;//静态变量public static void main(String[] args)  {Thread t=new Thread(()->{while(!isQuit){System.out.println("hello t");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}System.out.println("线程结束");});t.start();try {Thread.sleep(3000);} catch (InterruptedException e) {throw new RuntimeException(e);}//主线程中修改isQuit的值isQuit=true;}
}

这里为啥一定要把isQuit设置为静态全局变量呢,因为如果放在lambda表达式里,会进行变量捕获,有两个要求,设置的变量必须是final修饰或者是实际final的,啥意思呢

final修饰的就是个常量了

实际final指的是虽然不是个常量,,没有用final修饰,但是没有尝试去修改它的值

而如果这个代码中将isQuit放入lambda表达式中,在主线程中对它又进行了修改,所以会报错.所以最好的方式就是将它作为静态全局变量

如图所示,我们可以看到报红了 

上述是一种方式,需要程序员手动设置标志位,那么我们也可以采用Thread类内置的标志位来进行

线程中断

上代码来进行更好的讲解

public class ThreadDemo2 {//currentThread是获取当前线程实例的方法//isInterrupted是t对象自带的一个标志位//interrupt方法就是设置标志位为truepublic static void main(String[] args) {Thread t=new Thread(()->{while(!Thread.currentThread().isInterrupted()){System.out.println("hello   t");try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}});t.start();try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}t.interrupt();}
}

我们先来运行一下这个代码,看看结果

发现了吗,这个线程并没有结束,而是打印了三次,抛出异常,然后继续执行

代码中的e.printStackPrace()打印的是异常调用栈 

为啥线程没有按照预期结束呢

首先主线程休眠3000ms,t线程打印三次,这时isInterrupted本身是false,然后主线程苏醒,,调用interrupt方法,将标志位边为true,这时候t线程执行到了sleep那里,那么sleep被提前唤醒,清空了标志位,将true再次变为false,那么这个循环一直为真,也就会一直执行了


那么我们要怎样解决这个问题呢

手动加break

public class ThreadDemo2 {//currentThread是获取当前线程实例的方法//isInterrupted是t对象自带的一个标志位//interrupt方法就是设置标志位为truepublic static void main(String[] args) {Thread t=new Thread(()->{while(!Thread.currentThread().isInterrupted()){System.out.println("hello   t");try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();break;}}});t.start();try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}t.interrupt();}
}

看运行结果

 那么为什么sleep要清空标志位呢

让线程对于啥时候结束有一个更精准的控制

使用interrupt不是让线程立即结束,而是告诉线程应该结束了,真正线程结束取决于我们怎样写代码😊


2.线程等待

线程之间是并发执行的,对于线程调度是无序的,我们要想确定线程执行顺序,需要使用线程等待

线程等待这个比较简单,就是使用join,来举个例子

public class ThreadDemo3 {public static void main(String[] args) throws InterruptedException {Thread t=new Thread(()->{System.out.println("hello t");});t.start();t.join();System.out.println("hello main");}
}

在主线程中中使用t.join()意思是让主线程阻塞等待,t线程结束以后,再执行主线程

这里有一个误区,让主线程阻塞不是说除了t线程其他所有线程都阻塞了,而是除了主线程阻塞,其他线程照常执行,不受影响

 

这样就保证了线程的执行顺序

如果主线程中调用t.join()时,t正在执行,那么主线程就阻塞等待,直到t线程结束,主线程接着执行

如果主线程调用t.join()时,t已经执行完毕,那么主线程就直接执行即可


3.线程休眠

已经写过很多遍了,就是sleep,就不再赘述了

下一个问题

线程获取实例,

在讲线程中断的时候,也讲过了,currenrtThread()方法就是获取一个线程的实例


线程状态

1.NEW(线程还未创建,就是有个Thread对象)

2.RUNNABLE(正在CPU调度或者即将上CPU调度)

3.TERMINATED(线程已经执行完毕,Thread对象还在)

4.BLOCKED(等待锁出现的状态)

5.TIME_WAITING(指定时间等待.sleep方法)

6.WAITING(使用wait方法出现的状态)

下面通过代码来看一看

public class ThreadDemo12 {public static void main(String[] args) throws InterruptedException {Thread t = new Thread(() -> {while (true) {// System.out.println("hello");try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}});// 在启动之前, 获取线程状态. NEWSystem.out.println(t.getState());t.start();//Thread.sleep(2000);System.out.println(t.getState());}
}

public class ThreadDemo12 {public static void main(String[] args) throws InterruptedException {Thread t = new Thread(() -> {while (true) {// 为了防止 hello会将线程状态覆盖掉 , 先注释这一行// System.out.println("hello");try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}});//  未启动,NEWSystem.out.println(t.getState());t.start();Thread.sleep(2000);System.out.println(t.getState());}
}

 


 总结

线程的状态

NEW

RUNNABLE

TERMINATED

这三个状态是线程的主要状态


然后BLOCKED,TIME_WAITING,WAITING,都是线程执行中可能出现的状态,

简称,一条主线,三个分支,BLOCKED和WAITING后期再讲

今天的讲解就到这里,我们下期再见,886!!!

相关内容

热门资讯

【ZYNQ】无串口配置 Lin... 背景 基于 Zynq 自制板卡搭载了嵌入式 Linux 系统,因无预留串口设备...
【面试】-- Hive高频面试... 一、请描述一下数据倾斜,并提供解决方案?  定义:由于数据分布不均匀,导致大量数据集中到一点,造成...
BFC块级格式化上下文 一、概念 BFC - Block Formatting Context 块级格式化上下文 BFC的定...
Proteus常用元件查找对照   Proteus的这25大类元器件分别为: Analog ICs 模拟ICCMOS ...
DRAM功能介绍与基础概念 目录   ROM与RAM DRAM定义与形态 DRAM存储单元 DRAM架构和工作流程 存储器是计算...
C++面经 编译、链接与库编译单文件编译多文件编译动态链接与静态链接静态链接动态链接面向对象c++...
python例程:玛丽冒险 目录《玛丽冒险》程序使用说明开发环境要求运行方法主要代码展示源码及说明文档下载路径 《玛丽冒险》程...
学习笔记-架构的演进之服务网格... 文章目录前言通信的成本第一阶段第二阶段第三阶段第四阶段第五阶段总结附 前言 Kubernetes 为...
大数据集群保姆级安装教程——F... 大数据集群保姆级安装教程——Flume 1.1 安装地址 (1) Flu...
(大数据开发随笔5)Scala... 泛型 泛型类 // 创建一个通用类,技能操作Int类型,又能操作Stri...
java实现“数据平滑升级” 文章目录一、摘要二、前提场景说明:三、项目用到的脚本和代码1.项目目录长这样2.jav...
操作系统概述 操作系统概述 文章目录操作系统概述操作系统的基本概念4个特征并发(Concurrenc...
leetcode每日一题27 263. 丑数 按题意写 class Solution {public:bool isUgly(in...
从0开始学python -65 Python urllib-2 模拟头部信息 我们抓取网页一般需要对 headers(...
kafka-producer ... Kafka需要在吞吐量和延迟之间取得平衡,可通过下面两个参数控制。 batch.size 当多个消息...
tomcat 9 编码问题导致... tomcat编码设置问题 由于刚更换tomcat 9 ,没有修改配置文件,...
XShell安装配置教程及云服... 目录一、 XShell的作用二、 下载XShell1.访问XShell官网,填写姓名和...
批量下载文档有救了:Pytho... 人生苦短,我用python 最近毕业季要做毕业设计的同学真的特别多 需要大量文献、文档...
从数据中获得成功!学会如何使用... 在当今数字化的世界中,社交媒体已成为企业推广产品和服务的主要渠道之一。然而࿰...
tpm2-tools源码分析之... 接前一篇文章tpm2-tools源码分析之tpm2_getrandom.c(1...