java高并发之线程组详解

package com.itsoku.chat02; 

import java.util.concurrent.TimeUnit;  

/**

  * <b>description</b>：<br>   

  * <b>time</b>：2019/7/13 17:53 <br>  

  * <b>author</b>：微信公众号：路人甲Java，专注于java技术分享（带你玩转 爬虫、分布式事务、异步消息服务、任务调度、分库分表、大数据等），喜欢请关注！ 

  */

public class Demo1 {   

     public static class R1 implements Runnable {   

         @Override   

         public void run() {

             System.out.println( "threadName:" + Thread.currentThread().getName());  

             try {  

                 TimeUnit.SECONDS.sleep( 3 ); 

             } catch (InterruptedException e) { 

                 e.printStackTrace();   

             }  

         }  

     }  

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

         ThreadGroup threadGroup = new ThreadGroup( "thread-group-1" );   

         Thread t1 = new Thread(threadGroup, new R1(), "t1" );   

         Thread t2 = new Thread(threadGroup, new R1(), "t2" );   

         t1.start();

         t2.start();

         TimeUnit.SECONDS.sleep( 1 ); 

         System.out.println( "活动线程数:" + threadGroup.activeCount());  

         System.out.println( "活动线程组:" + threadGroup.activeGroupCount()); 

         System.out.println( "线程组名称:" + threadGroup.getName());  

     }  

}

public ThreadGroup(String name)    

public ThreadGroup(ThreadGroup parent, String name)

public ThreadGroup(String name) {  

         this (Thread.currentThread().getThreadGroup(), name);   

     }

package com.itsoku.chat02; 

import java.util.concurrent.TimeUnit;  

/**

  * <b>description</b>：<br>   

  * <b>time</b>：2019/7/13 17:53 <br>  

  * <b>author</b>：微信公众号：路人甲Java，专注于java技术分享（带你玩转 爬虫、分布式事务、异步消息服务、任务调度、分库分表、大数据等），喜欢请关注！ 

  */

public class Demo2 {   

     public static class R1 implements Runnable {   

         @Override   

         public void run() {

             Thread thread = Thread.currentThread();

             System.out.println( "所属线程组:" + thread.getThreadGroup().getName() + ",线程名称:" + thread.getName());

             try {  

                 TimeUnit.SECONDS.sleep( 3 ); 

             } catch (InterruptedException e) { 

                 e.printStackTrace();   

             }  

         }  

     }  

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

         ThreadGroup threadGroup1 = new ThreadGroup( "thread-group-1" );  

         Thread t1 = new Thread(threadGroup1, new R1(), "t1" );  

         Thread t2 = new Thread(threadGroup1, new R1(), "t2" );  

         t1.start();

         t2.start();

         TimeUnit.SECONDS.sleep( 1 ); 

         System.out.println( "threadGroup1活动线程数:" + threadGroup1.activeCount()); 

         System.out.println( "threadGroup1活动线程组:" + threadGroup1.activeGroupCount());

         System.out.println( "threadGroup1线程组名称:" + threadGroup1.getName()); 

         System.out.println( "threadGroup1父线程组名称:" + threadGroup1.getParent().getName());

         System.out.println( "----------------------" );  

         ThreadGroup threadGroup2 = new ThreadGroup(threadGroup1, "thread-group-2" );

         Thread t3 = new Thread(threadGroup2, new R1(), "t3" );  

         Thread t4 = new Thread(threadGroup2, new R1(), "t4" );  

         t3.start();

         t4.start();

         TimeUnit.SECONDS.sleep( 1 ); 

         System.out.println( "threadGroup2活动线程数:" + threadGroup2.activeCount()); 

         System.out.println( "threadGroup2活动线程组:" + threadGroup2.activeGroupCount());

         System.out.println( "threadGroup2线程组名称:" + threadGroup2.getName()); 

         System.out.println( "threadGroup2父线程组名称:" + threadGroup2.getParent().getName());

         System.out.println( "----------------------" );  

         System.out.println( "threadGroup1活动线程数:" + threadGroup1.activeCount()); 

         System.out.println( "threadGroup1活动线程组:" + threadGroup1.activeGroupCount());

         System.out.println( "----------------------" );  

         threadGroup1.list();   

     }  

}

package com.itsoku.chat02; 

/**

  * <b>description</b>：<br>   

  * <b>time</b>：2019/7/13 17:53 <br>  

  * <b>author</b>：微信公众号：路人甲Java，专注于java技术分享（带你玩转 爬虫、分布式事务、异步消息服务、任务调度、分库分表、大数据等），喜欢请关注！ 

  */

public class Demo3 {   

     public static void main(String[] args) {   

         System.out.println(Thread.currentThread());

         System.out.println(Thread.currentThread().getThreadGroup());   

         System.out.println(Thread.currentThread().getThreadGroup().getParent());   

         System.out.println(Thread.currentThread().getThreadGroup().getParent().getParent());   

     }  

}

private ThreadGroup() {     // called from C code  

         this .name = "system" ;  

         this .maxPriority = Thread.MAX_PRIORITY;

         this .parent = null ;

     }

package com.itsoku.chat02; 

import java.util.concurrent.TimeUnit;  

/**

  * <b>description</b>：<br>   

  * <b>time</b>：2019/7/13 17:53 <br>  

  * <b>author</b>：微信公众号：路人甲Java，专注于java技术分享（带你玩转 爬虫、分布式事务、异步消息服务、任务调度、分库分表、大数据等），喜欢请关注！ 

  */

public class Demo4 {   

     public static class R1 implements Runnable {   

         @Override   

         public void run() {

             Thread thread = Thread.currentThread();

             System.out.println( "所属线程组:" + thread.getThreadGroup().getName() + ",线程名称:" + thread.getName());

             while (!thread.isInterrupted()) {  

                 ;  

             }  

             System.out.println( "线程:" + thread.getName() + "停止了！" ); 

         }  

     }  

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

         ThreadGroup threadGroup1 = new ThreadGroup( "thread-group-1" );  

         Thread t1 = new Thread(threadGroup1, new R1(), "t1" );  

         Thread t2 = new Thread(threadGroup1, new R1(), "t2" );  

         t1.start();

         t2.start();

         ThreadGroup threadGroup2 = new ThreadGroup(threadGroup1, "thread-group-2" );

         Thread t3 = new Thread(threadGroup2, new R1(), "t3" );  

         Thread t4 = new Thread(threadGroup2, new R1(), "t4" );  

         t3.start();

         t4.start();

         TimeUnit.SECONDS.sleep( 1 ); 

         System.out.println( "-----------threadGroup1信息-----------" );

         threadGroup1.list();   

         System.out.println( "----------------------" );  

         System.out.println( "停止线程组：" + threadGroup1.getName() + "中的所有子孙线程" );

         threadGroup1.interrupt();  

         TimeUnit.SECONDS.sleep( 2 ); 

         System.out.println( "----------threadGroup1停止后，输出信息------------" );  

         threadGroup1.list();   

     }  

}