"地瓜哥"博客网

对线程分组是Java并发API提供的一个有趣功能。我们可以将一组线程看成一个独立单元，并且可以随意操纵线程组中的线程对象。比如，可以控制一组线程来运行同样的任务，无需关心有多少线程还在运行，还可以使用一次中断调用中断所有线程的执行。

Java提供了ThreadGroup类来控制一个线程组。一个线程组可以通过线程对象来创建，也可以由其他线程组来创建，生成一个树形结构的线程。

根据《Effective Java》的说明，不再建议使用ThreadGroup。建议使用Executor。

——D瓜哥特此说明。

在本节，我们就使用ThreadGroup来开发一个简单的示例。我们将创建十个休眠时间不等的线程（比如模拟搜索），当其中一个完成时，中断其余线程。

知其然

按照下面所示步骤，完成示例代码。

1. 创建一个名为Result的类，用于存储第一个完成任务的线程的名字。声明一个String类型的私有变量，name，同时生成Setter/Getter方法。代码如下：

   查看源代码

   打印帮助

   01	public class Result {

   02	private String name;

   03

   04	public String getName() {

   05	return name;

   06

   }

   07

   08	public void setName(String name) {

   09	this.name = name;

   10

   }

   11

   }

2. 创建一个名为SearchTask的类，并实现Runnable接口。代码如下：

   查看源代码

   打印帮助

   1	public class SearchTask implements Runnable {

3. 声明一个Result类型的私有变量，并通过构造函数来实例化该变量。代码如下：

   查看源代码

   打印帮助

   1	private Result result;

   2

   3	public SearchTask(Result result) {

   4	this.result = result;

   5

   }

4. 实现run()方法，在其中调用doTask()方法，来等待完成或被中断。该方法还向控制台打印信息来显示线程的开始、结束或者中断。代码如下：

   查看源代码

   打印帮助

   01

   @Override

   02	public void run() {

   03	String name = Thread.currentThread().getName();

   04	System.out.printf("Thread %s: Start\n", name);

   05

   try {

   06

   doTask();

   07	result.setName(name);

   08	} catch (InterruptedException e) {

   09	System.out.printf("Thread %s: Interrupted\n", name);

   10

   return;

   11

   }

   12	System.out.printf("Thread %s: End\n", name);

   13

   }

5. 实现doTask()方法，该方法将创建一个Random对象，然后使用该对象生成一个随机数，来调节线程休眠的时间。代码如下：

   查看源代码

   打印帮助

   1

   // 模拟搜索

   2	private void doTask() throws InterruptedException {

   3	Random random = new Random(new Date().getTime());

   4	int value = (int) (random.nextDouble() * 100);

   5	System.out.printf("Thread %s: %d\n",

   6	Thread.currentThread().getName(), value);

   7	TimeUnit.SECONDS.sleep(value);

   8

   }

6. 创建示例程序的主类，Main，并实现main()方法。代码如下：

   查看源代码

   打印帮助

   1	public class Main {

   2	public static void main(String[] args) {

7. 创建一个名称为Searcher的ThreadGroup对象。代码如下：

   查看源代码

   打印帮助

   1	ThreadGroup threadGroup = new ThreadGroup("Searcher");

8. 然后，创建一个Result对象和SearchTask对象。代码如下：

   查看源代码

   打印帮助

   1	Result result = new Result();

   2	SearchTask searchTask = new SearchTask(result);

9. SearchTask对象使用创建十个Thread对象，并且创建Thread对象时，将ThreadGroup对象作为第一个参数，传递给Thread类的构造函数。代码如下：

   查看源代码

   打印帮助

   1	for (int i = 0; i < 5; i++) {

   2	Thread thread = new Thread(threadGroup, searchTask);

   3	thread.start();

   4

   try {

   5	TimeUnit.SECONDS.sleep(1);

   6	} catch (InterruptedException e) {

   7	e.printStackTrace();

   8

   }

   9

   }

10. 使用list()方法将ThreadGroup对象的信息打印出来。代码如下：

    查看源代码

    打印帮助

    1	System.out.printf("Number of Threads: %d\n", threadGroup.activeCount());

    2	System.out.println("Information about the Thread Group");

    3	threadGroup.list();

11. 使用activeCount()和enumerate()来获取ThreadGroup对象中的活跃线程数并将其复制到一个线程数组中。使用get*()方法，获取线程的名称和状态。代码如下：

    查看源代码

    打印帮助

    1	Thread[] threads = new Thread[threadGroup.activeCount()];

    2	threadGroup.enumerate(threads);

    3	for (int i = 0; i < threadGroup.activeCount(); i++) {

    4	System.out.printf("Thread %s: %s\n", threads[i].getName(),

    5	threads[i].getState());

    6

    }

12. 调用waitFinish()方法，等待ThreadGroup对象中的其中一个线程完成任务。稍后实现该方法。代码如下：

    查看源代码

    打印帮助

    1	waitFinish(threadGroup);

13. 使用interrupt()方法，中断线程组中其他线程。代码如下：

    查看源代码

    打印帮助

    1	threadGroup.interrupt();

14. 实现waitFinish()方法，使用activeCount()方法控制线程的执行结果。代码如下：

    查看源代码

    打印帮助

    01

    // 等待任务完成

    02	private static void waitFinish(ThreadGroup threadGroup) {

    03	while (threadGroup.activeCount() > 9) {

    04

    try {

    05	TimeUnit.SECONDS.sleep(1);

    06	} catch (InterruptedException e) {

    07	e.printStackTrace();

    08

    }

    09

    }

    10

    }

15. 运行程序，查看执行效果。

知其所以然

下面是程序执行的结果。你将看到list()方法的输出，各个线程的状态等。

ThreadGroup类保存着众多Thread对象以及关联的ThreadGroup对象。可以通过调用该类的方法，访问线程的信息，还可以对其进行各种操作，比如中断等。

永无止境

ThreadGroup类还有好多方法。请翻阅API文档，查看完整的方法说明。

拿来主义

本文是从 《Java 7 Concurrency Cookbook》 （D瓜哥窃译为 《Java7并发示例集》 ）翻译而来，仅作为学习资料使用。没有授权，不得用于任何商业行为。

小有所成

下面是本节示例所用的代码的完整版。

Result类的完整代码

SearchTask类的完整代码

Main类的完整代码