# ThreadGroup API介绍
TreadGroup其实是在1.5之前用的比较多,在没有线程池API前都使用TreadGroupApi来管理线程池。虽然现在有线程池API来供大家使用,但是如果在平时开发中只想启用三五个线程,那么可以选择使用TreadGroup来管理线程。
我们找到ThreadGroup来看一下:
![](https://img.kancloud.cn/25/e4/25e41ab9d98756206dfd4eb83861f5bc_1040x196.png)
线程组表示一组线程。此外,线程组还可以包括其他线程组。线程组形成一个树,其中除了初始线程组外,每个线程组都有一个父线程组。
允许线程访问关于其自己线程组的信息,但不允许访问关于其线程组的父线程组或任何其他线程组的信息。
那么,允许线程访问关于其自己线程组的信息的信息都是什么呢?我们接下来看一下:
首先创建一个threadgroup
```java
public class ThreadGroupCreate {
public static void main(String[] args) {
// 1. use the name
ThreadGroup tg1 = new ThreadGroup("TG1");
Thread t1 = new Thread(tg1, () -> {
while (true) {
try {
Thread.sleep(10_000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}, "T1");
t1.start();
System.out.println("t1's thread group name = " + t1.getThreadGroup().getName());// TG1
//todo 2. use the parent and group name
}
}
```
运行效果如下:
![](https://img.kancloud.cn/b5/cf/b5cf77e79d3a6e7734ee4c1264046ac9_856x228.gif)
打印一下当前threadgroup的名字和他父级的名字:
```java
ThreadGroup threadGroup = Thread.currentThread().getThreadGroup();
System.out.println(threadGroup.getName());
System.out.println(threadGroup.getParent());
```
运行效果如下:
![](https://img.kancloud.cn/c8/f5/c8f53b73fd473c9eec218da2795a0fa2_856x210.gif)
可以看到他的线程组是TG1,他的夫级线程组是main,并且main线程的优先级很高是10。
接下来我们给创建另一个线程组,他的夫级线程组TG1:
```java
//2. use the parent and group name
ThreadGroup tg2 = new ThreadGroup(tg1, "TG2");
System.out.println("tg2's name = " + tg2.getName());
System.out.println("tg2's parent name = " + tg2.getParent().getName());
```
运行效果如下:
![](https://img.kancloud.cn/57/63/5763b80196fb7bf2cd42b4318f796118_856x210.gif)
线程组两种创建方式就ok了,我们再来验证一下:**允许线程访问关于其自己线程组的信息,但不允许访问关于其线程组的父线程组或任何其他线程组的信息**。
```java
//TG2 访问TG1
ThreadGroup tg2 = new ThreadGroup(tg1, "TG2");
Thread t2 = new Thread(tg2,()->{
System.out.println("tg2's parent threadgroup is"+tg2.getName());
});
t2.start();
// TG3与TG1为同一个父ThreadGroup-main
// 测试TG3能否访问TG1的一些信息
ThreadGroup tg3 = new ThreadGroup("TG3");
Thread t3 = new Thread(tg3, () -> {
System.out.println(">>>>" + t1.getName());// TG1
Thread[] threads = new Thread[tg1.activeCount()];
tg1.enumerate(threads);
Stream.of(threads).forEach(System.out::println);// Thread[T1,5,TG1]
}, "T3");
t3.start();
```
运行效果如下:
可以看到其实是可以访问的,可能是官方文档有问题,也有可能是我翻译的有问题。。。
## 接下来学习几个ThreadGroup的常用方法:
#### activeCount()
![](https://img.kancloud.cn/17/e6/17e66efebb2e29ff25be745fb9686c34_936x74.png)
返回此线程组及其子组中活动线程的评估数量。这里注意是评估数量,因为可能获取的时候,某个线程消亡了或者正在被添加。
```java
public class ThreadGroupAPI {
public static void main(String[] args) {
ThreadGroup tg1 = new ThreadGroup("TG1");
Thread t1 = new Thread(tg1, () -> {
while (true) {
try {
Thread.sleep(1_000);
} catch (InterruptedException e) {
e.printStackTrace();
break;
}
}
}, "T1");
/*tg1.setDaemon(true);*/
t1.start();
ThreadGroup tg2 = new ThreadGroup(tg1, "TG2");
Thread t2 = new Thread(tg2, () -> {
while (true) {
try {
Thread.sleep(1_000);
} catch (InterruptedException e) {
e.printStackTrace();
break;
}
}
}, "T2");
t2.start();
System.out.println("tg1 active count is " + tg1.activeCount());
}
}
```
运行效果如下:
![](https://img.kancloud.cn/2d/d5/2dd551cec66963b7a1b5f4657b408b0c_856x204.gif)
#### activeGroupCount()
![](https://img.kancloud.cn/d8/ad/d8adf4dfa87bf6c32bb9da1856d72370_988x73.png)
返回此线程组及其子组中活动组的评估数量。
```java
System.out.println(tg1.activeGroupCount());
```
运行效果如下:
![](https://img.kancloud.cn/41/c4/41c4fdaa7e6069e839688e97de7b84b6_856x204.gif)
#### checkAccess()
![](https://img.kancloud.cn/ec/86/ec86f140dcc70baa88c448b81b36c80b_974x183.png)
确定当前运行的线程是否具有修改此线程组的权限。
代码如下:
```java
tg1.checkAccess();
```
运行效果如下:
![](https://img.kancloud.cn/73/c0/73c0aed27de40a0d0500f7a3ddb2bbef_856x204.gif)
没抛出异常代表有权限修改线程组。
#### destroy()
![](https://img.kancloud.cn/4e/7f/4e7fcb1d5631be321c7879745d7f09bc_1001x358.png)
销毁这个线程组及其所有子组。destroy前需要确定线程组里没有活跃的线程。如果线程组不为空或线程组已被销毁将抛出`IllegalThreadStateException`
代码如下:
```java
tg1.destroy();
```
运行效果如下:
![](https://img.kancloud.cn/cf/f8/cff8748ac36a557d497ee06eaecdd489_856x204.gif)
因为我们线程里有while,所以是活跃的线程,这里就抛出异常了。
#### enumerate(Thread[] list)
![](https://img.kancloud.cn/e0/9e/e09e82ceef838da81735587a37052198_1007x63.png)
将此线程组及其子组中的每个活动线程复制到指定的数组中。
代码如下:
```java
Thread[] ts1 = new Thread[tg1.activeCount()];
tg1.enumerate(ts1);
System.out.println(Arrays.toString(ts1));
```
运行效果如下:
![](https://img.kancloud.cn/83/77/837708808a254e70da07d5fefcc9eaa0_856x204.gif)
#### enumerate(Thread[] list, boolean recurse)
![](https://img.kancloud.cn/65/42/6542dd63177dab38570e94f03b74844a_989x59.png)
将此线程组中的每个活动线程复制到指定数组中。
代码如下:
```java
Thread[] ts2 = new Thread[tg1.activeCount()];
tg1.enumerate(ts2, false);
System.out.println(Arrays.toString(ts2));
```
运行效果如下:
![](https://img.kancloud.cn/27/8a/278ae01318a672e540c5a5c1d26a8306_856x204.gif)
![](https://img.kancloud.cn/f3/27/f3279d4eb8de00be721f15cb3a1e7b7e_695x89.png)
如果为真,则递归枚举此线程组的所有子组。那么我们使用false试试:
```java
ThreadGroup mainThreadGroup = Thread.currentThread().getThreadGroup();
Thread[] ts3 = new Thread[mainThreadGroup.activeCount()];
mainThreadGroup.enumerate(ts3, false);
System.out.println(Arrays.toString(ts3));
```
运行效果如下:
![](https://img.kancloud.cn/06/93/0693469c5f2090606ad1784b4141a75c_856x204.gif)
#### interrupt()
![image-20200919161631996](23.ThreadGroup API介绍.assets/image-20200919161631996.png)
中断此线程组中的所有线程。
代码如下:
```java
tg1.interrupt();
```
运行效果如下:
![](https://img.kancloud.cn/e8/43/e8434754e9fe1973313a4b749c21aefc_856x204.gif)
#### setDaemon(boolean daemon)
![](https://img.kancloud.cn/74/42/744241563a82d74a95162876b5e4317b_977x337.png)
守护进程——如果为真,则将此线程组标记为守护线程组;否则,将此线程组标记为normal。
```java
ThreadGroup tg1 = new ThreadGroup("TG1");
Thread t1 = new Thread(tg1, () -> {
try {
Thread.sleep(1_000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}, "T1");
tg1.setDaemon(true);
t1.start();
Thread.sleep(2_000);
System.out.println(tg1.isDestroyed());
```
运行效果如下:
![](https://img.kancloud.cn/72/08/72085452b18ce08afd6cf263c5c29281_856x204.gif)
注释tg1.setDaemon(true);试一下:
![](https://img.kancloud.cn/f4/65/f4658dada63c8fd5fe6ce065a98d442b_856x204.gif)
手动销毁一下:
```java
ThreadGroup tg1 = new ThreadGroup("TG1");
Thread t1 = new Thread(tg1, () -> {
try {
Thread.sleep(1_000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}, "T1");
//tg1.setDaemon(true);
t1.start();
Thread.sleep(2_000);
System.out.println(tg1.isDestroyed());
tg1.destroy();
System.out.println(tg1.isDestroyed());
```
运行效果如下:
![](https://img.kancloud.cn/e8/3f/e83f109c12355e772e73c497d6356327_856x204.gif)
这篇随笔是我周六没吃早饭没吃午饭弄到下午4点38才弄完的,中间多少次想休息一会吃个饭再继续弄,但是还是想弄完了再好好吃饭,也许这样下去永远都胖不起来吧。。。
- 微服务
- 服务器相关
- 操作系统
- 极客时间操作系统实战笔记
- 01 程序的运行过程:从代码到机器运行
- 02 几行汇编几行C:实现一个最简单的内核
- 03 黑盒之中有什么:内核结构与设计
- Rust
- 入门:Rust开发一个简单的web服务器
- Rust的引用和租借
- 函数与函数指针
- Rust中如何面向对象编程
- 构建单线程web服务器
- 在服务器中增加线程池提高吞吐
- Java
- 并发编程
- 并发基础
- 1.创建并启动线程
- 2.java线程生命周期以及start源码剖析
- 3.采用多线程模拟银行排队叫号
- 4.Runnable接口存在的必要性
- 5.策略模式在Thread和Runnable中的应用分析
- 6.Daemon线程的创建以及使用场景分析
- 7.线程ID,优先级
- 8.Thread的join方法
- 9.Thread中断Interrupt方法学习&采用优雅的方式结束线程生命周期
- 10.编写ThreadService实现暴力结束线程
- 11.线程同步问题以及synchronized的引入
- 12.同步代码块以及同步方法之间的区别和关系
- 13.通过实验分析This锁和Class锁的存在
- 14.多线程死锁分析以及案例介绍
- 15.线程间通信快速入门,使用wait和notify进行线程间的数据通信
- 16.多Product多Consumer之间的通讯导致出现程序假死的原因分析
- 17.使用notifyAll完善多线程下的生产者消费者模型
- 18.wait和sleep的本质区别
- 19.完善数据采集程序
- 20.如何实现一个自己的显式锁Lock
- 21.addShutdownHook给你的程序注入钩子
- 22.如何捕获线程运行期间的异常
- 23.ThreadGroup API介绍
- 24.线程池原理与自定义线程池一
- 25.给线程池增加拒绝策略以及停止方法
- 26.给线程池增加自动扩充,闲时自动回收线程的功能
- JVM
- C&C++
- GDB调试工具笔记
- C&C++基础
- 一个例子理解C语言数据类型的本质
- 字节顺序-大小端模式
- Php
- Php源码阅读笔记
- Swoole相关
- Swoole基础
- php的五种运行模式
- FPM模式的生命周期
- OSI网络七层图片速查
- IP/TCP/UPD/HTTP
- swoole源代码编译安装
- 安全相关
- MySql
- Mysql基础
- 1.事务与锁
- 2.事务隔离级别与IO的关系
- 3.mysql锁机制与结构
- 4.mysql结构与sql执行
- 5.mysql物理文件
- 6.mysql性能问题
- Docker&K8s
- Docker安装java8
- Redis
- 分布式部署相关
- Redis的主从复制
- Redis的哨兵
- redis-Cluster分区方案&应用场景
- redis-Cluster哈希虚拟槽&简单搭建
- redis-Cluster redis-trib.rb 搭建&原理
- redis-Cluster集群的伸缩调优
- 源码阅读笔记
- Mq
- ELK
- ElasticSearch
- Logstash
- Kibana
- 一些好玩的东西
- 一次折腾了几天的大华摄像头调试经历
- 搬砖实用代码
- python读取excel拼接sql
- mysql大批量插入数据四种方法
- composer好用的镜像源
- ab
- 环境搭建与配置
- face_recognition本地调试笔记
- 虚拟机配置静态ip
- Centos7 Init Shell
- 发布自己的Composer包
- git推送一直失败怎么办
- Beyond Compare过期解决办法
- 我的Navicat for Mysql
- 小错误解决办法
- CLoin报错CreateProcess error=216
- mysql error You must reset your password using ALTER USER statement before executing this statement.
- VM无法连接到虚拟机
- Jetbrains相关
- IntelliJ IDEA 笔记
- CLoin的配置与使用
- PhpStormDocker环境下配置Xdebug
- PhpStorm advanced metadata
- PhpStorm PHP_CodeSniffer