线程的四种操作

2024-09-09 04:52
文章标签 线程 操作 四种

本文主要是介绍线程的四种操作,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

  所属专栏:Java学习     

在这里插入图片描述

 

1. 线程的开启

start和run的区别:

run:描述了线程要执行的任务,也可以称为线程的入口

start:调用系统函数,真正的在系统内核中创建线程(创建PCB,加入到链表中),此处的start会根据不同的系统,分别调用不同的api,创建好之后的线程,再单独去执行run(所以说,start的本质是调用系统api,系统的api会在内核中创建线程)

start执行的速度是比较快的,一旦 start 执行完毕,新线程就会开始执行,调用start的线程,main线程也会继续执行

在Java中,一个Thread对象只能对应到一个系统中的线程,在start中就会根据线程的状态来判断,如果Thread对象没有start,此时的状态就是一个new状态,可以顺利调用start,如果已经调用过start,就会进入到其他状态,只要不是new状态,都会抛出异常

2. 线程的终止

当线程B正在运行时,如果发生了特殊情况需要终止掉线程,有两种实现方式:

  1. 通过共享的标记来进行沟通
  2. 调用interrupt()方法来通知

先来看使用自定义的isQuit作为标志位的例子:

public class ThreadDemo4 {private static boolean isQuit = false;public static void main(String[] args) throws InterruptedException {Thread thread = new Thread(){@Overridepublic void run() {while (!isQuit){System.out.println("thread");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}System.out.println("thread线程终止了");}};thread.start();Thread.sleep(1000);System.out.println("main线程尝试终止thread线程...");isQuit = true;}
}

这时就有一个问题需要注意:

如果isQuit不用static修饰,改为main方法里的局部变量可行不可行?ans:肯定是不可行的

这就涉及到了lambda表达式变量捕获的问题了

变量捕获是lambda表达式/匿名内部类中的一个语法规则:isQuit和lambda表达式定义在一个作用域中,此时lambda内部是可以访问到外部(和lambda同一个作用域)中的变量的,Java中的变量捕获是有一个特殊要求的,要求捕获的变量必须是final或事实final(虽然不是final修饰,但是后面没有更改)

就如上面的代码中,isQuit后面是被修改了的,所以就违反了语法规则

刚开始的形式为什么可以:写在外面就是外部类的成员变量,内部类本来就是可以访问外部类的

再来看interrupted的例子:

Thread类里面有一个boolean类型的成员变量interrupted,初始状态为false,一旦外面有线程调用interrupt方法,就会设置标志位为true

public class ThreadDemo5 {public static void main(String[] args) throws InterruptedException {Thread thread = new Thread(()->{Thread currentThread = Thread.currentThread();while (!currentThread.isInterrupted()){System.out.println("thread");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}});thread.start();Thread.sleep(1000);//主线程中控制thread被终止,设置标志位thread.interrupt();}
}

看起来是和自定义的标志位一样的,但是运行之后就会发现出现了异常:

由于在循环中判断和打印的操作太快了,整个循环的时间都是花在sleep方法里的,当main中调用interrupt时,大概率线程thread是在sleep中的,此时Interrupt就不仅能设置标志位,还可以唤醒thread线程,就会抛出InterruptedException异常,catch中捕获到异常也是做了抛出处理,就交给了JVM,程序就异常终止,那么把处理异常的方式更改一下试试:

这时就会发现while循环中的代码一直在执行

这里的原因是当sleep等阻塞函数被唤醒之后,就会清空刚刚设置的标志位,这时interrupted就一直是初始状态,也就导致了死循环,如果需要结束循环,可以把刚刚的异常处理直接改为break。

Java中终止线程的方式:A线程希望B线程能够终止,B线程收到这样的请求之后就可以自行决定是否是立即终止,稍后终止还是直接无视

  1. 如果B线程想要无视A,catch中就什么也不做,B线程就继续执行(sleep清除标志位)
  2. 如果B线程想要立即结束,就在catch中直接break或return
  3. 如果B线程想要稍后再终止,就可以在catch中添加其他的逻辑(释放资源,清理数据,提交结果...),这些完成之后再break/return.

3. 线程的等待

在之前提到过,操作系统针对多个线程的执行是一个“随机执行,抢占式调度”的过程,哪条线程先执行和先结束是不确定的,不过可以通过使用线程等待来决定哪条线程先结束,也就是让最后结束的线程等待先结束的线程,此时后结束的线程就进入了阻塞状态

例如在a线程中调用b.join(),就是让a线程等待b线程先结束,然后a再继续执行

public class ThreadDemo6 {public static void main(String[] args) {Thread thread1 = new Thread(() -> {for (int i = 0; i < 3; i++) {System.out.println("thread1");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}System.out.println("thread1结束了");});thread1.start();System.out.println("main线程开始等待");try {thread1.join();} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println("main线程结束等待");}
}

上面的代码是thread1线程先执行,然后main线程开始等待,进入阻塞状态,如果说修改为先让thread1线程结束,main线程再开始等待会如何呢?

此时join并没有发生阻塞,join方法就是确保被等待的线程能够先结束,如果已经结束了,就没有等待的必要了

此外,任何线程都可以等待别的线程,而且可以等待多个线程,或者是多个线程之间互相等待

public class ThreadDemo7 {public static void main(String[] args) throws InterruptedException {Thread t1 = new Thread(()->{for(int i = 0;i < 3;i++){System.out.println("线程t1执行...");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}System.out.println("线程t1结束");});Thread t2 = new Thread(()->{for(int i = 0;i < 3;i++){System.out.println("线程t2执行...");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}System.out.println("线程t2结束");});t1.start();t2.start();System.out.println("main线程开始等待...");t1.join();t2.join();System.out.println("main线程结束等待");}
}

这就是main线程同时等待两个线程的例子,关于两个join的顺序其实没有区别,最终都是等待了4s

在main等待t1和t2同时,t2也可以等待t1:

这样就把原来t1和t2并发执行修改为了t1先执行

main线程也可以被其他线程等待,不过写法不同的是,需要先获取main线程的引用

public class ThreadDemo8 {public static void main(String[] args) throws InterruptedException {Thread mainThread = Thread.currentThread();Thread thread = new Thread(()->{System.out.println("thread等待main线程");try {mainThread.join();} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println("结束等待");});thread.start();Thread.sleep(1000);System.out.println("main线程结束");}
}

在上面使用的join方法中,由于是没有传入参数的,就表示被等待的线程只要没有执行完,就会一直等待,这种方式肯定是不好的,如果被等待的线程出现问题了,就会使这个等待操作一直进行,所以就有了传参的版本,但上面列举的第三个高精度的一般也用不到

4. 线程的休眠

之前一直用的Thread.sleep()这个操作就是让调用的线程阻塞等待一定时间的,线程执行sleep之后,就会使这个线程不参与CPU的调度,把CPU的资源让出来,给其他线程使用,在开发时,如果发现某个线程的CPU占用率过高,就可以通过sleep来改善,虽然说线程的优先级也可以影响,但比较有限

在这里插入图片描述

这篇关于线程的四种操作的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1150210

相关文章

SQL中JOIN操作的条件使用总结与实践

《SQL中JOIN操作的条件使用总结与实践》在SQL查询中,JOIN操作是多表关联的核心工具,本文将从原理,场景和最佳实践三个方面总结JOIN条件的使用规则,希望可以帮助开发者精准控制查询逻辑... 目录一、ON与WHERE的本质区别二、场景化条件使用规则三、最佳实践建议1.优先使用ON条件2.WHERE用

Java中实现线程的创建和启动的方法

《Java中实现线程的创建和启动的方法》在Java中,实现线程的创建和启动是两个不同但紧密相关的概念,理解为什么要启动线程(调用start()方法)而非直接调用run()方法,是掌握多线程编程的关键,... 目录1. 线程的生命周期2. start() vs run() 的本质区别3. 为什么必须通过 st

Linux链表操作方式

《Linux链表操作方式》:本文主要介绍Linux链表操作方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、链表基础概念与内核链表优势二、内核链表结构与宏解析三、内核链表的优点四、用户态链表示例五、双向循环链表在内核中的实现优势六、典型应用场景七、调试技巧与

Linux实现线程同步的多种方式汇总

《Linux实现线程同步的多种方式汇总》本文详细介绍了Linux下线程同步的多种方法,包括互斥锁、自旋锁、信号量以及它们的使用示例,通过这些同步机制,可以解决线程安全问题,防止资源竞争导致的错误,示例... 目录什么是线程同步?一、互斥锁(单人洗手间规则)适用场景:特点:二、条件变量(咖啡厅取餐系统)工作流

Java Multimap实现类与操作的具体示例

《JavaMultimap实现类与操作的具体示例》Multimap出现在Google的Guava库中,它为Java提供了更加灵活的集合操作,:本文主要介绍JavaMultimap实现类与操作的... 目录一、Multimap 概述Multimap 主要特点:二、Multimap 实现类1. ListMult

Java中常见队列举例详解(非线程安全)

《Java中常见队列举例详解(非线程安全)》队列用于模拟队列这种数据结构,队列通常是指先进先出的容器,:本文主要介绍Java中常见队列(非线程安全)的相关资料,文中通过代码介绍的非常详细,需要的朋... 目录一.队列定义 二.常见接口 三.常见实现类3.1 ArrayDeque3.1.1 实现原理3.1.2

SpringBoot3中使用虚拟线程的完整步骤

《SpringBoot3中使用虚拟线程的完整步骤》在SpringBoot3中使用Java21+的虚拟线程(VirtualThreads)可以显著提升I/O密集型应用的并发能力,这篇文章为大家介绍了详细... 目录1. 环境准备2. 配置虚拟线程方式一:全局启用虚拟线程(Tomcat/Jetty)方式二:异步

Python中文件读取操作漏洞深度解析与防护指南

《Python中文件读取操作漏洞深度解析与防护指南》在Web应用开发中,文件操作是最基础也最危险的功能之一,这篇文章将全面剖析Python环境中常见的文件读取漏洞类型,成因及防护方案,感兴趣的小伙伴可... 目录引言一、静态资源处理中的路径穿越漏洞1.1 典型漏洞场景1.2 os.path.join()的陷

如何解决Druid线程池Cause:java.sql.SQLRecoverableException:IO错误:Socket read timed out的问题

《如何解决Druid线程池Cause:java.sql.SQLRecoverableException:IO错误:Socketreadtimedout的问题》:本文主要介绍解决Druid线程... 目录异常信息触发场景找到版本发布更新的说明从版本更新信息可以看到该默认逻辑已经去除总结异常信息触发场景复

Python使用Code2flow将代码转化为流程图的操作教程

《Python使用Code2flow将代码转化为流程图的操作教程》Code2flow是一款开源工具,能够将代码自动转换为流程图,该工具对于代码审查、调试和理解大型代码库非常有用,在这篇博客中,我们将深... 目录引言1nVflRA、为什么选择 Code2flow?2、安装 Code2flow3、基本功能演示