(三)线程组和线程优先级

news2024/10/6 8:35:45

(三)线程组和线程优先级

  • 3.1 线程组(ThreadGroup)
  • 3.2 线程的优先级
    • 01、Thread 的优先级
    • 02、ThreadGroup 和 Thread 优先级不一致问题
  • 3.3 守护线程(Daemon)
  • 3.4 线程组的常用方法
  • 3.5 线程组的数据结构

3.1 线程组(ThreadGroup)

Java 中用 ThreadGroup 来表示线程组,我们可以使用线程组对线程进行批量控制。

ThreadGroup 和 Thread 的关系就像他们的名字一样:每个 Thread 必然存在于一个 ThreadGroup 中,Thread 不能独立位于 ThreadGroup 存在。执行 main() 方法线程的名字是 main,如果在 new Thread() 时没有显式指定,那么默认将父线程(当前执行 new Thread() 的线程)的线程组设置为自己的线程组。

来看个例子:

/**
 * 线程组测试
 *
 * @author qiaohaojie
 * @date 2023/7/3  14:45
 */
public class ThreadGroupTest {
    public static void main(String[] args) {
        Thread thread1 = new Thread(() -> {
            System.out.println("testThread 当前线程组名字:" + Thread.currentThread().getThreadGroup().getName()); // testThread 当前线程组名字:main
            System.out.println("testThread 线程名字:" + Thread.currentThread().getName()); // testThread 线程名字:Thread-0
        });

        thread1.start();
        System.out.println("执行main所在线程的线程组名字:" + Thread.currentThread().getThreadGroup().getName()); // 执行main所在线程的线程组名字:main
        System.out.println("执行main方法的线程名字:" + Thread.currentThread().getName()); // 执行main方法的线程名字:main
    }
}

运行结果:
在这里插入图片描述
由执行结果可知,执行的顺序是:先执行线程组,再执行线程。也就是说,ThreadGroup 管理着它下面的 Thread,ThreadGroup 是一个标准的向下引用的树状结构,这样设计的原因是防止上级线程被下级线程引用而无法有效地被 GC 回收

3.2 线程的优先级

01、Thread 的优先级

Java 中线程的优先级可以指定,范围是 1~10。但是并不是所有的操作系统都支持 10 级优先级的划分(比如有些操作系统只支持 3 级划分:低,中,高),Java 只是给操作系统一个优先级的参考值,线程最终在操作系统的优先级是多少还是由操作系统决定。

Java 默认的线程优先级为 5,线程的执行顺序由调度程序来决定,线程的优先级会在线程被调用之前设定。

通常情况下,高优先级的线程将会比低优先级的线程有更高的几率得到执行。使用方法 Thread 类的 setPriority() 实例方法来设定线程的优先级。

来看例子:

/**
 * 线程组测试
 *
 * @author qiaohaojie
 * @date 2023/7/3  14:45
 */
public class ThreadGroupTest {
    public static void main(String[] args) {
        /**
         * 线程的优先级
         */
        Thread threadA = new Thread();
        System.out.println("默认线程优先级:" + threadA.getPriority()); // 默认线程优先级:5
        Thread threadB = new Thread();
        threadB.setPriority(10);
        System.out.println("设置过线程优先级后:" + threadB.getPriority()); // 设置过线程优先级后:10
   }
}

既然有 1~10 的级别来设定线程的优先级,那么是不是就可以在业务实现的时候采用这种方法来指定一些线程执行的先后顺序呢?

答案是:不可以!

其实,Java 中的优先级并不是特别的可靠,Java 程序中对线程所设置的优先级只是给操作系统的一个建议,操作系统也并不一定会采纳。而真正的调用顺序是由操作系统的线程调度算法决定的。

通过代码验证一下:

/**
 * 线程组测试
 *
 * @author qiaohaojie
 * @date 2023/7/3  14:45
 */
public class ThreadGroupTest {
    public static void main(String[] args) {
        IntStream.range(1, 10).forEach(i -> {
            Thread thread = new Thread(new Test());
            thread.setPriority(i);
            thread.start();
        });
    }

	public static class Test extends Thread {
        @Override
        public void run() {
            super.run();
            System.out.println(String.format("当前执行的线程是:%s,优先级是:%d",
                    Thread.currentThread().getName(), Thread.currentThread().getPriority()));
        }
    }
}

某次运行结果(操作系统线程调度机制决定运行结果,有多种情况):
在这里插入图片描述
Java 提供一个线程调度器来监视和控制处于 RUNNABLE 状态的线程。线程的调度策略采用抢占式,优先级高的线程比优先级低的线程会有更大的几率优先执行。在优先级相同的情况下,按照 “先到先得” 的原则,每个 Java 程序都有一个默认的主线程,就是通过 JVM 启动的第一个线程 main 线程。

02、ThreadGroup 和 Thread 优先级不一致问题

我们都知道,一个线程必然存在于一个线程组中,那么当线程和线程组的优先级不一致时会怎么呢?

上代码:

/**
 * 线程组测试
 *
 * @author qiaohaojie
 * @date 2023/7/3  14:45
 */
public class ThreadGroupTest {
    public static void main(String[] args) {
        /**
         * 线程组的优先级
         */
        ThreadGroup threadGroup = new ThreadGroup("t1");
        threadGroup.setMaxPriority(6);
        Thread thread = new Thread(threadGroup, "thread");
        thread.setPriority(9);
        // 如果某个线程的优先级大于线程所在线程组的最大优先级,那么该线程的优先级将会失效,取而代之的是线程组的最大优先级
        System.out.println("线程组的优先级:" + threadGroup.getMaxPriority()); // 线程组的优先级:6
        System.out.println("线程的优先级:" + thread.getPriority()); // 线程的优先级:6
    }
}

由此可见,如果某个线程的优先级大于线程所在线程组的最大优先级,那么该线程的优先级将会失效,取而代之的是线程组的最大优先级。

3.3 守护线程(Daemon)

守护线程是一种支持型线程,它主要被用作后台调度以及支持性工作。守护线程默认的优先级比较低。如果某线程是守护线程,如果所有的非守护线程都结束了,这个守护线程也会自动结束(当一个 Java 虚拟机中不存在非守护线程的时候,Java 虚拟机将会退出)。

一个线程默认是非守护线程,可以通过 Thread 类的 setDaemon(true) 方法来设置,Daemon 属性需要在启动线程之前设置,不能在启动之后设置。

看例子:

/**
 * 线程组测试
 *
 * @author qiaohaojie
 * @date 2023/7/3  14:45
 */
public class ThreadGroupTest {
    public static void main(String[] args) {
        /**
         * 守护线程
         */
        Thread daemonThread = new Thread(new DaemonThread(), "daemonThread");
        daemonThread.setDaemon(true);
        daemonThread.start();
    }

    public static class DaemonThread implements Runnable {
        @Override
        public void run() {
            try {
                TimeUnit.SECONDS.sleep(10);
            } catch (InterruptedException e) {
                e.printStackTrace();
            } finally {
                System.out.println("DaemonThread finally run.");
            }
        }
    }
}

可以看到终端或命令提示符界面没有任何输出,main 线程(非守护线程)在启动了 DaemonThread 线程之后随着 main 方法的执行结束而终止了,而此时 Java 虚拟机中已经没有非守护线程了,所以 Java 虚拟机需要退出,同时 Java 虚拟机中所有的线程都要立即终止,因此 DaemonThread 守护线程直接终止,finally 代码块中的语句并没有执行。

注意:在构建守护线程时,不能依靠 finally 块中的内容来确保执行关闭或清理资源的逻辑。

结论:

如果某线程是守护线程,那当其他所有的非守护线程都结束了,这个守护线程也会自动结束。

应用场景是:当所有非守护线程结束时,其余的子线程(守护线程)自动关闭,就免去了还要继续关闭子线程的麻烦。

3.4 线程组的常用方法

  • 获取当前线程组的名字

    // 1. 获取当前线程组的名字
    Thread.currentThread().getThreadGroup().getName();
    
  • 复制线程组

    // 2. 获取当前的线程组
    ThreadGroup threadGroup1 = Thread.currentThread().getThreadGroup();
    // 3. 复制一个线程组到一个线程数组(获取thread信息)
    Thread[] threads = new Thread[threadGroup1.activeCount()];
    threadGroup1.enumerate(threads);
    
  • 线程组统一异常处理

    // 4. 线程组统一异常处理
    ThreadGroup threadGroup2 = new ThreadGroup("group1") {
        // 继承ThreadGroup并重新定义以下方法
        // 在线程成员抛出unchecked exception会执行此方法
        public void unCaughtException(Thread t, Throwable e) {
            System.out.println(t.getName() + ":" + e.getMessage());
        }
    };
    // 这个线程是threadGroup2的一员
    Thread thread2 = new Thread(threadGroup2, new Runnable() {
        @Override
        public void run() {
            // 抛出异常
            throw new RuntimeException("测试异常");
        }
    });
    thread2.start();
    

    运行结果:

    在这里插入图片描述

3.5 线程组的数据结构

线程组还可以包含其他的线程组,不仅仅是线程。

先来看看 ThreadGroup 源码中的成员变量:

public class ThreadGroup implements Thread.UncaughtExceptionHandler {
    private final ThreadGroup parent; // 父亲ThreadGroup
    String name; // ThreadGroupr 的名称
    int maxPriority; // 线程最大优先级
    boolean destroyed; // 是否被销毁
    boolean daemon; // 是否守护线程
    boolean vmAllowSuspension; // 是否可以中断
 
    int nUnstartedThreads = 0; // 还未启动的线程
    int nthreads; // ThreadGroup中线程数目
    Thread threads[]; // ThreadGroup中的线程
 
    int ngroups; // 线程组数目
    ThreadGroup groups[]; // 线程组数组
}

再来看构造函数:

// 私有构造函数
private ThreadGroup() { 
    this.name = "system";
    this.maxPriority = Thread.MAX_PRIORITY;
    this.parent = null;
}

// 默认是以当前ThreadGroup传入作为parent ThreadGroup,新线程组的父线程组是目前正在运行线程的线程组。
public ThreadGroup(String name) {
    this(Thread.currentThread().getThreadGroup(), name);
}

// 构造函数
public ThreadGroup(ThreadGroup parent, String name) {
    this(checkParentAccess(parent), parent, name);
}

// 私有构造函数,主要的构造函数
private ThreadGroup(Void unused, ThreadGroup parent, String name) {
    this.name = name;
    this.maxPriority = parent.maxPriority;
    this.daemon = parent.daemon;
    this.vmAllowSuspension = parent.vmAllowSuspension;
    this.parent = parent;
    parent.add(this);
}

第三个构造函数调用了 checkParentAccess() 方法:

// 检查parent ThreadGroup
private static Void checkParentAccess(ThreadGroup parent) {
    parent.checkAccess();
    return null;
}

// 判断当前运行的线程是否具有修改线程组的权限
public final void checkAccess() {
    SecurityManager security = System.getSecurityManager();
    if (security != null) {
        security.checkAccess(this);
    }
}

这里还涉及到 SecurityManager 类,它是 Java 的安全管理器,它允许应用程序在执行一个可能不安全或敏感的操作前确定该操作是什么,以及是否是在允许执行该操作的安全上下文中执行它。应用程序可以允许或不允许该操作。比如:引入了第三方类库,但是并不能保证它的安全性。

其实 Thread 类也有一个 checkAccess() 方法,不过是用来当前运行的线程是否有权限修改被调用的这个线程实例。(Determines if the currently running thread has permission to modify this thread.)

总结来说,线程组是一个树状的结构,每个线程组下面可以有多个线程或者线程组。线程组可以起到统一控制线程的优先级和检查线程的权限的作用。

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

@RequestParam注解注意事项

在传参的时候,有的参数不是必传的,代码如下: 比如现在name为必传,position为非必传,我们来用postman测试下, 直接报如上图所示的错误,那么有什么办法阻止这个错误了,只要在不必传的参…

SpringBoot使用mybatis批量新增500万数据到mysql数据库Demo

SpringBoot使用mybatis批量新增500万数据到mysql数据库Demo 说明项目Demo代码地址项目目录mysql对应表建表语句pom.xmlapplication.yml配置类启动类代码OrderInfo 实体类TestController控制层接口层TestServiceTestServiceImpl实现层TestDao数据接口层dao层对应mapper.xml自定义…

熔断降级与限流在开源SpringBoot/SpringCloud微服务框架的最佳实践

目录导读 熔断降级与限流在开源SpringBoot/SpringCloud微服务框架的最佳实践1. 开源代码整体架构设计2. 微服务逻辑架构设计3. 微服务熔断降级与限流规划3.1 微服务熔断降级与限流场景分析3.2 微服务熔断降级与限流技术栈规划3.3 微服务熔断降级与限流技术选型3.3.1 熔断降级中…

自动化测试之selenium工具使用

1. 自动化测试的前提 1.1 什么是自动化? 减少人力成本完成大量重复性工作提高测试效率保证工作的一致性,提高信任度完成手工不能完成的工作 1.2 是否适合做自动化? 时间 (项目周期长)人员 (熟悉自动化&…

神经网络术语解释

目录 Padding: 填充步幅(stride)Pooling Layer:池化层Batch NormalizationSeparable ConvolutionsREFERENCE Padding: 填充 在进行卷积层的处理之前,有时要向输入数据的周围填入固定的数据(比 如0等&#…

redis高可用集群数据库的安装部署(6.2.12版本)

第三阶段基础 时 间:2023年7月3日 参加人:全班人员 内 容: 6.2.12版本redis集群部署 目录 一、环境配置:【两台服务器】 二、redis多实例配置: 三、构建redis cluster集群 四、创建主从 五、故障转移实验 …

IT安全部门应如何平衡企业内外部文件交换的业务效率与安全性?

在日常运营经营中,很多企业存在与外部客户的业务数据往来,如生产型企业与上下游供应链间的制造设计相关文件交换、金融企业与外部监管机构和合作方间的重要客户数据收发、文化娱乐产业内外部关于作品素材的传输交流等。当内外部数据文件交换较为频繁、且…

什么是Web3.0?

鲁迅先生曾言:“人一旦有钱,智商和情商都会是高86.4%,烦恼也会消失100%。”然而,问题来了,钱从哪里来?他只留下了一串数字Dle577。同时,莎士比亚也指出,这个世界上只有少数人能够把握…

《安全软件开发框架(SSDF) 1.1:降低软件漏洞风险的建议》解读(四)

安全软件开发框架SSDF是由美国国家标准与技术研究院发布的关于安全软件开发的一组实践,帮助开发组织减少发布的软件中的漏洞数量,减少利用未检测到或未解决的漏洞的潜在影响,从根本上解决漏洞防止再次发生。本文根据《Secure Software Develo…

防火墙基本原理详解

概要 防火墙是可信和不可信网络之间的一道屏障,通常用在LAN和WAN之间。它通常放置在转发路径中,目的是让所有数据包都必须由防火墙检查,然后根据策略来决定是丢弃或允许这些数据包通过。例如: 如上图,LAN有一台主机和一…

【业务功能篇38】上篇:Springboot+activiti7 工作流引擎 增加网关组件、Assignment分配权限

在前面的一篇文章中,简单举例了一个 工单电子流,【业务功能篇36】Springbootactiviti7 工作流引擎_studyday1的博客-CSDN博客仅有一个子任务,这种一般是针对比较简单的一个遗留问题记录场景,今天再介绍一个,相对比较复…

为什么放弃Java后,没有使用Kotlin,新的开发语言正在席卷而来

放弃Java后,没有使用Kotlin 从 Java 到Kotlin,Kotlin作为Android官方支持语言,获得了更多的关注和采用! 这几年,Kotlin的发展势头很猛,可以说由 Java 转 Kotlin 早已势不可挡。 那么Kotlin有哪些优势可以…

AI视觉赢未来|深眸科技出席元宇宙装备展,“智与质”实现双重升级

6月29日,2023昆山元宇宙国际装备展在昆山国际会展中心圆满落幕,此次展会不仅为我们呈现最先进的元宇宙装备、最前沿的元宇宙技术、最潮流的元宇宙应用,还为工业元宇宙的发展蓄势赋能。 浙江深眸科技有限公司(以下简称深眸科技&am…

数据太大了?快来试试这款地理空间数据云管理平台

四维轻云是一款网页版地理空间数据云管理平台,用户能够在线管理、浏览及分享倾斜模型(.osgb)、激光点云(.las)、正射影像(dom)、数字高程模型(dem)等数据。目前,平台具有数据管理、场景编辑、空间测量、团队协作、加密分享、素材库等功能。 项目管理 四…

【Linux】什么是文件系统及inode?如何创建软硬链接?软硬链接有什么作用?

inode软硬链接创建软硬链接理解硬链接理解软链接 inode 了解一下文件系统: Linux ext2文件系统,上图为磁盘文件系统图(内核内存映像肯定有所不同),磁盘是典型的块设备,硬盘分区被 划分为一个个的block。…

【Qt】程序异常结束。The process was ended forcefully.(解决方法不一样哦)

环境 系统:win10 64bit Qt:5.14.1 编译器:MinGW 32-bit 问题 Qt工程编译正常,但无法调试,报错:程序异常结束。The process was ended forcefully. 步骤 已尝试网上方法仍然不行的,可以直接…

为什么JDK动态代理只能代理接口?

在Java中,动态代理是一种机制,允许在运行时动态地创建代理对象来代替某个实际对象,从而在其前后执行额外的逻辑。 为什么JDK动态代理只能代理接口实现类,原因是JDK动态代理是基于接口实现的。 当你使用Proxy类创建代理对象时&am…

第一章:Linux常用命令+VIM+SSH介绍+SSH密钥登录

目录 一、Linux常用命令 1)# 与 $ 提示的区别 2)ifconfig 3) su 4) cd 5) 目录查看 6) 查看文件内容 7)创建目录及文件 8)复制和移动 9)其他 10) …

Git 上传Github 超时问题

提交代码到GitHub总是超时,偶尔会直接上传成功。 提供一下解决方案 1.首先找到网络 2. 找到代理 3. 把自动检查设置全部关闭,然后打开手动设置代理,然后输入ip地址和你代理的端口号,保存即可。 4. 最后使用git push origin mast…

多边形偏移算法【Polygon Offsetting】

在本教程中,我们将描述一种膨胀或收缩多边形的算法。 推荐:用 NSDT设计器 快速搭建可编程3D场景。 1、一般形式的同调 为了简单起见,让我们从一个形状开始,一个正方形。 我们可能熟悉通过放大或缩小形状来缩放形状的想法。 从技术…