多线程(二):创建线程关键属性终止线程

目录

1、run & start

 2、Thread类常见的属性和方法

2.1 构造方法

2.2 属性

3、后台进程 & 前台进程

4、后台线程的判断和设定——isDaemon & setDaemon

5、线程是否存活——isAlive

6、终止一个线程

6.1 lambda变量捕获

6.2 currentThread & isInterrupted & interrupt

6.2.1 sleep被唤醒


1、run & start

在多线程(一)的博客中,为大家介绍了五种创建线程的方式,但从大类上分也就是两大类——分别是通过自定义类继承Thread以及自定义类实现Runnable接口(解耦合)来实现。

这两种方式中,都用到了start方法以及run方法,这里再次强调一下两种方法的作用及区别。

  • start方法的作用是真正在系统中创建线程并启动线程(由JVM调用操作系统的api完成线程创建操作)。
  • start是jvm提供的方法,本质上是调用操作系统提供的api。
  • start是native修饰的本地方法,说明是在JVM内部实现的,并由C++代码实现(JVM由C++实现)
  •  每个Thread对象,都只能start一次,也就是说一个Thread对象只能创建一个线程。每想创建一个新的线程,就需要创建一个新的Thread对象。(“日抛”,一次性的)
  • run方法是线程的入口方法,不需要手动调用,当新的线程启动后就会自动调用。
  • run方法相当于一个“回调函数”。什么是“回调函数”?简单来说,就是这个方法自己不用,让别人去用。举个例子:我们使用优先级队列(堆)时,需要指定比较规则,其中Comparable的compareTo方法以及Comparator的compare方法就是回调函数。

 2、Thread类常见的属性和方法

2.1 构造方法

相信大家对于前两个构造方法并不陌生,就是我们上文所提到创建线程的两种方法。

而第三种和第四种,则是额外给创建的线程自定义名字。

给线程起名字,其作用就是方便我们程序员调试(通过名字描述线程的作用),哪怕线程的名字相同也不会影响线程的执行。

如下图所示:

我们就可以观察到我们自定义的两个名为t1、t2的两个线程正在运行。 

但是,我们并没有发现主线程main,这是为什么呢?

——这是因为主线程中已经结束了(main中并没有死循环代码,主线程main早已执行完毕了~~)。

我们之前的认知时,main是程序的入口,main执行完程序(进程)就执行完毕了,其实这只是针对于单线程程序来说的。在多线程中,非也~~

我们当然也可以通过写死循环代码来观察主线程main。

public class Demo6 {
    public static void main(String[] args) throws InterruptedException {
        Thread t1 = new Thread(() -> {
            while (true) {
                System.out.println("hello t1");
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
            }
        }, "t1");
        t1.start();

        Thread t2 = new Thread(() -> {
            while (true) {
                System.out.println("hello t2");
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
            }
        }, "t2");
        t2.start();

        while (true) {
            System.out.println("hello main");
            Thread.sleep(1000);
        }
    }
}

2.2 属性

  • ID就类似于pid,是线程的唯⼀标识,不同线程不会重复。
  • 名称,即我们给线程自定义的名字,没有自定义则为系统默认的名字。
  • 状态,优先级这里就不再赘述。

线程中含有多个属性,我们可以通过Thread中相应的方法进行获取。 


3、后台进程 & 前台进程

我们需要先了解 前台线程 与 后台线程。

前台线程 的作用大,能够直接影响进程是否执行完毕。当所有的前台线程都执行完后,进程才能结束,要是有一个前台线程没有结束,整个进程都不能结束。

我们自己创建的线程,包括main主线程,都是前台线程。

后台线程,又称为 守护线程,Deamon就是守护的意思。说明这个线程 是默默守护的,他们的存在,不会影响 进程 的结束。

一些JVM自带的线程,就是后台线程,他们的存在左右不了进程的结束。简单来说,如果进程要结束,不会问这些后台线程的意见,进程要是想结束,那他们就必须跟着结束,进程结束后,他们也会随之结束。

有些后台线程存在的意义不是很大,即使没有他们,也没啥影响。但是,有些后台线程是JVM提供的一些具有特殊功能的线程,会跟随整个进程持续执行(不能随便离开),比如:垃圾回收进程。

前台线程 和 后台线程 都是有多个的。

如果有多个前台线程,必须所有的 前台线程 结束后,进程才能结束。

4、后台线程的判断和设定——isDaemon & setDaemon

  • isDaemon方法用来 判断 线程是否为 后台线程。
  • setDaemon方法是将 前台线程 修改 为后台线程。注意:必须在线程创建前修改(即调用start方法前使用setDaemon方法修改)

将 前台线程 修改为 后台线程 后,这些线程将无力阻止进程的结束。

此时,仅有一个前台线程main,当main结束后,整个进程将会结束,虽然t1处于循环状态,但t1为后台线程,不会影响整个进程的状态。

  • 进程间存在 父子关系 ,但线程间不存在。

比如 IDEA 本身就是一个进程,打开 IDEA 后运行的Java代码又是一个进程,这就是进程间的父子关系。 

5、线程是否存活——isAlive

isAlive方法用来判断线程是否存活。

在Java中,Thread创建的对象和线程是一一对应的关系。

但是Thread对象的生命周期和所创建的线程的生命周期是不同的,可能存在线程已经结束,但是Thread对象依旧存活的情况。

我们将线程设置为存活3s,但是发现却打印出了4个true,这是由于并发时操作系统随机调度的原因,主线程的第四次打印,和thread线程结束,谁先谁后,是不一定的~~

在这里就是,在主线程第四次打印true时(主线程先被调度执行),thread线程还有一口气,但是马上就无了~~


6、终止一个线程

"终止" 指的是让一个线程结束,且不会再恢复了。

当一个线程的入口方法执行完毕后,线程也就随即结束了。

那么让一个线程提前终止,其实就是让run方法尽早return而已。

6.1 lambda变量捕获

我们可以通过变量设置,控制线程的存活时间。

此时可以得到我们想要的结果。

此时的isFinish为成员变量,但是当我们把isFinish放到main方法中当做局部变量时,却发生了报错,这是为什么呢?

它告诉我们,isFinish应该是final类型或者事实上为final类型的,也就是说isFinish的值不能发生改变。

这是因为,在lambda内部,触发了“变量捕获”的语法,而我们在下面的代码中对isFinish进行了修改,所以发生了报错。

因为lambda本来就是用于“回调函数”使用的,而 回调函数 执行时机是不确定的,可能是很久以后才进行线程的创建,而此时main这个主线程可能早已经执行完毕了,那么main内部的局部变量早已销毁。

为解决上述问题,Java将被捕获的变量拷贝了一份,传到了lambda的内部,以此让lambda能够使用外面的局部变量。但是,拷贝的变量,就意味着这个变量和原本的变量不是同一个东西,当一方进行修改时,另一方不会随之改变。而这边变,那边又不变,就会给程序猿带来更多的问题~~

为解决这个问题,Java大佬们这样决定,就根本不允许这个变量进行修改。这就是“变量捕获”的语法,被捕获的变量必须是final或事实上为final的(不是final类型,但是变量值没有改变)。

而当我们将isFinish设置为成员变量时,此时就不再是“变量捕获”语法的范畴,而切换为“内部类访问外部类成员”的语法(lambda本来就是实现函数式接口的匿名内部类的简化形式,本质上就是一个内部类),而“内部类访问外部类成员”的语法本来就是正确的。

对象本体以及其中的成员变量的生命周期都是由GC(垃圾回收)进行管理的,不会随方法的结束而销毁。

当final修饰引用类型时,不能修改引用的指向(不能将这个引用指向别的对象),但是可以修改引用指向的对象本体。

6.2 currentThread & isInterrupted & interrupt

  • isInterrupted方法的作用就是判断线程是否被终止。
 

lambda表达式的执行是在对象new之前,此时的thread引用还没有被声明。

我们需要使用Thread的静态方法currentThread获取线程的引用。

  • currentThread方法在哪个线程内部被调用,获取的就是哪个线程的Thread引用。而这个代码是在 lambda 中 (也就是在 thread 线程的入口run方法中) 调用的,获取的就是 thread 线程的引用。(类似于this)

故 Thread.currentThread().isInterrupted() 的作用就是,判断线程是否被终止了。

  • interrupt方法的作用是去主动终止线程(修改内部的boolean变量(标志位)值)
 

当我们设置好终止线程的方法后,运行发现有异常抛出,被JVM捕获,导致程序直接终止:

这是由于调用interrupt方法的原因:

  1. interrupt方法不仅会修改线程内部的boolean变量值
  2. thread线程内绝大部分时间处于sleep的休眠状态(其他代码执行速度很快),而interrupt方法会提前唤醒sleep(sleep休眠时间未到就被唤醒了),而sleep就会抛出InterruptedException异常
  3. 抛出异常后,由于catch块内没有将异常处理好,则会直接带走整个进程

而我们不想让线程"掀桌",我们可以修改 IDEA 默认的处理异常的方式,使用 break 替换,使线程更加优雅的终止:

public static void main(String[] args) throws InterruptedException {

        Thread thread = new Thread(() -> {
            //这个代码是在 lambda 中 (也就是在 thread 线程的入口run方法中) 调用的,获取的就是 thread 线程的引用
            while (!Thread.currentThread().isInterrupted()) {
                try {
                    System.out.println("hello thread");
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    // 唤醒sleep,抛出异常,catch捕获后再次抛出新异常
                    // 线程的 “掀桌” 操作
                    //throw new RuntimeException(e);
                    break;
                }
            }
            System.out.println("thread 结束");
        }, "thread");
        thread.start();

        Thread.sleep(3000);
        // 主动终止线程
        System.out.println("main 尝试终止线程thread");
        thread.interrupt();

    }

6.2.1 sleep被唤醒

虽说是优雅了,但是依然是interrupt唤醒了sleep,抛出异常,通过catch逻辑来进行的线程终止操作。

如果我们在catch块中将break去除后(catch中空着),线程还会终止吗???

我们发现,当去掉break后,即使在主线程中通过interrupt方法修改了t线程的标志位,但线程依旧没有终止,这是为什么呢???

其实,这是由于sleep在搞鬼。

  • 正常情况下,我们通过interrupt方法将isInterrupted内的标志位设置为了true
  • 但是由于sleep方法是被唤醒的,sleep在被唤醒之后,又把这个标志位的值设置回了false

所以当循环在次执行到循环条件判定时,循环就会继续执行。

其实Java对于sleep的这种设定,是为了让程序员在catch块中有更多的选择空间——当外部通知线程终止时,程序员可以选择立即终止、也可以选择一会再终止、也可以选择不终止。

我们程序猿可以根据线程的执行情况,再次自行设定线程终止的时机,让线程执行出一些"阶段性"结果时,再来终止线程,以至于避免线程执行一半就被强行终止,避免出现执行出"不上不下"的结果。


END

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

使用three.js 实现蜡烛效果

使用three.js 实现蜡烛效果 import * as THREE from "three" import { OrbitControls } from "three/examples/jsm/controls/OrbitControls.js"var scene new THREE.Scene(); var camera new THREE.PerspectiveCamera(60, window.innerWidth / window.in…

【opengl学习】opengl的compute shader

目的 opengl虽然老,但是算上opengl es,应该是应用最广泛的显卡api。用compute shader做计算,可以一定程度上摆脱N卡的限制,也摆脱windows和linux,mac等平台的限制。 计算着色器应该没有完全榨干硬件的性能&#xff0c…

CUDA - 如何让线程和内存对应

前提: 本文的目的就是设置的程序中,每个线程可以负责一个单独的计算任务。帮助学习和理解线程是如何组织的。 本文处理一个二维数据的加法。 数据在内存中的存储 以线性、行为主的方式存储。 例如,一个16*8的一维数组,在内存…

站在用户视角审视:以太彩光与PON之争

作者:科技作家-郑凯 园区,是企业数字化转型的“中心战场”。 云计算、大数据、人工智能等数智化技术在园区里“战火交织”;高清视频、协同办公,智慧安防等大量创新应用产生的海量数据在园区内“纵横驰骋”;加上大量的IOT和智能化设备涌入“战场”,让园区网络面对着难以抵御的…

查看PyTorch的GPU使用情况的工具

文章目录 torch.cuda APIPyTorch SnapshotPyTorch ProfilerNVIDIA Nsight Systemstorchinfo torch.cuda API torch.cuda.memory_stats:返回给定设备的 CUDA 内存分配器统计信息字典。该函数的返回值是一个统计字典,每个字典都是一个非负整数。torch.cud…

antDesign Form.List下的Form.Item如何通过setFieldsValue设置值

翻了一下antDesign官网只看见了Form可以使用setFieldsValue设置值,却没找到Form.List使用setFieldsValue设置值。 于是研究了一下!!!!!! 我的解决方案是: 先设置为空数组, 再设置成…

利用编程思维做题之反转链表

牛客网题目 1. 理解问题 给到我们的是一个单链表的头节点 pHead,要求反转后,返回新链表的头节点。 首先在心里设想能够快速理解的例子,如给你123序列,要你反转此序列如何回答?将最后一个数字3作为头,然后修…

学习threejs,THREE.MeshBasicMaterial网格材质、THREE.MeshLambertMaterial漫反射材质

👨‍⚕️ 主页: gis分享者 👨‍⚕️ 感谢各位大佬 点赞👍 收藏⭐ 留言📝 加关注✅! 👨‍⚕️ 收录于专栏:threejs gis工程师 文章目录 一、🍀前言1.1 ☘️THREE.MeshBasicMaterial网…

MATLAB代码解析:利用DCGAN实现图像数据的生成

摘要 经典代码:利用DCGAN生成花朵 MATLAB官方其实给出了DCGAN生成花朵的示范代码,原文地址:训练生成对抗网络 (GAN) - MATLAB & Simulink - MathWorks 中国 先看看训练效果 训练1周期 训练11周期 训练56个周期 脚本文件 为了能让各位…

centos7 Oracle 11g rac 静默安装(NFS配置共享存储)

1.环境信息准备 注意: 在配置网络时,Oracle RAC的每个节点必须具有至少两个以上的网卡,一张网卡对外提供网络服务,另一张网卡用于各个节点间的通信和心跳检测等。在配置RAC集群的网卡时,如果节点1的公共接口是eth0&…

下一代安全:融合网络和物理策略以实现最佳保护

在当今快速发展的技术环境中,网络和物理安全融合变得比以往任何时候都更加重要。随着物联网 (IoT) 和工业物联网 (IIoT) 的兴起,组织在保护数字和物理资产方面面临着独特的挑战。 本文探讨了安全融合的概念、说明其重要性的实际事件以及整合网络和物理安…

本地装了个pytorch cuda

安装命令选择 pip install torch1.13.1cu116 torchvision0.14.1cu116 torchaudio0.13.1 --extra-index-url https://download.pytorch.org/whl/cu116 torch版本查看 python import torch print(torch.__version__) 查看pytorch能否使用cuda import torch# 检查CUDA是否可用…

鸿蒙NEXT开发-动画(基于最新api12稳定版)

注意:博主有个鸿蒙专栏,里面从上到下有关于鸿蒙next的教学文档,大家感兴趣可以学习下 如果大家觉得博主文章写的好的话,可以点下关注,博主会一直更新鸿蒙next相关知识 专栏地址: https://blog.csdn.net/qq_56760790/…

241014-绿联UGOSPro-通过虚拟机访问主机的用户目录及文件夹

如图所示,两种方式; 方式1: 通过Files中的Other Locations 添加主机ip,随后输入主机的用户名及密码即可系统及文件加载可能需要一段时间,有点卡,加载完应该就可以点击访问了 方式2: 通过命令行直接ssh/sftp userna…

【C++网络编程】(一)Linux平台下TCP客户/服务端程序

文章目录 Linux平台下TCP客户/服务端程序服务端客户端相关头文件介绍 Linux平台下TCP客户/服务端程序 图片来源:https://subingwen.cn/linux/socket/ 下面实现一个Linux平台下TCP客户/服务端程序:客户端向服务器发送:“你好,服务…

网络资源模板--Android Studio 实现简易新闻App

目录 一、项目演示 二、项目测试环境 三、项目详情 四、完整的项目源码 一、项目演示 网络资源模板--基于Android studio 实现的简易新闻App 二、项目测试环境 三、项目详情 登录页 用户输入: 提供账号和密码输入框,用户可以输入登录信息。支持“记…

[ComfyUI]Flux:国漫经典!斗破苍穹古熏儿之绮梦流光模型来袭

在数字艺术和创意领域,FLUX以其独特的虚实结合技术,已经成为艺术家和设计师们手中的利器。今天,我们激动地宣布,FLUX推出了一款全新的ComfyUI版本——Flux,它将国漫经典《斗破苍穹》中的古熏儿之绮梦流光模型完美融合&…

第十四章 RabbitMQ延迟消息之延迟队列

目录 一、引言 二、死信队列 三、核心代码实现 四、运行效果 五、总结 一、引言 什么是延迟消息? 发送者发送消息时指定一个时间,消费者不会立刻收到消息,而是在指定时间后收到消息。 什么是延迟任务? 设置在一定时间之后才…

Qt入门教程:创建我的第一个小程序

本章教程,主要介绍如何编写一个简单的QT小程序。主要是介绍创建项目的过程。 一、打开QT软件编辑器 这里使用的是QT5.14.2版本的,安装教程参考以往教程:https://blog.csdn.net/qq_19309473/article/details/142907096 二、创建项目 到这里&am…

使用Docker部署nextjs应用

最近使用nextjs网站开发,希望使用docker进行生产环境的部署,减少环境的依赖可重复部署操作。我采用的是Dockerfile编写应用镜像方式 docker-compose实现容器部署的功能。 Docker Docker 可以让开发者打包他们的应用以及依赖包到一个轻量级、可移植的容器…