Java并发包里面提供了ThreadGroup类可以帮助我们有效地管理线程组。让我们来看一个生动的例子. Java线程组可以有线程对象或者子线程组组成。也就是说ThreadGroup可以是产生线程树。
让我们看一个简单的例子,这个例子模仿一个搜索任务,将启动10个线程遍历获取指定目录下面的excel文件列表,一旦有一个线程完成遍历,将中断其余的9个任务。
import java.io.File;
import java.util.concurrent.TimeUnit;
public class SearchTask implements Runnable {
private String rootDir;
private SearchResult result;
public SearchTask(String rootDir, SearchResult result) {
super();
this.rootDir = rootDir;
this.result = result;
}
public String getRootDir() {
return rootDir;
}
public void setRootDir(String rootDir) {
this.rootDir = rootDir;
}
public SearchResult getResult() {
return result;
}
public void setResult(SearchResult result) {
this.result = result;
}
@Override
public void run() {
String name = Thread.currentThread().getName();
System.out.printf("Thread %s: Start\n",name);
try{
doSearch(new File(this.rootDir));
result.setTaskName(name);
}catch(InterruptedException e){
System.out.printf("Thread %s: Interrupted\n",name);
return;
}
System.out.printf("Thread %s: End\n",name);
}
private void doSearch(File root) throws InterruptedException{
if(root != null && root.isDirectory()){
TimeUnit.SECONDS.sleep(1);
File[] files = root.listFiles();
if( files != null ){
for(File file : files){
if(file.isFile() && file.getName().endsWith(".xls")){
result.getFiles().add(file.getAbsolutePath());
result.increaseCount();
}else if(file.isDirectory()){
doSearch(file);
}
}
}
}
}
}
package com.concurrent.exercise.threadgroup;
import java.util.ArrayList;
import java.util.List;
public class SearchResult {
private int count = 0;
private String taskName;
private List<String> files = new ArrayList<String>();
public String getTaskName() {
return taskName;
}
public void setTaskName(String taskName) {
this.taskName = taskName;
}
public void setCount(int count) {
this.count = count;
}
public void setFiles(List<String> files) {
this.files = files;
}
public int getCount() {
return count;
}
public void increaseCount() {
count++;
}
public List<String> getFiles(){
return files;
}
}
import java.util.concurrent.TimeUnit;
public class TestThreadGroup {
public static void main(String[] args){
String searchDir = "D:\\";
ThreadGroup threadGroup = new ThreadGroup("Searcher");
for(int i = 0; i < 3; i++){
SearchTask task = new SearchTask(searchDir,new SearchResult());
Thread thread = new Thread(threadGroup, task);
thread.start();
try{
TimeUnit.SECONDS.sleep(2);
}catch(InterruptedException e) {
e.printStackTrace();
}
}
waitFinish(threadGroup);
threadGroup.interrupt();
}
private static void waitFinish(ThreadGroup threadGroup) {
while (threadGroup.activeCount() > 2) {
try {
list(threadGroup);
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
private static void list(ThreadGroup threadGroup) {
assert(threadGroup != null);
threadGroup.list();
}
}
在启动三个线程后,进入waitFinish方法,当其中一个线程结束后,waitFinish立即对出并调用ThreadGroup终止剩下的线程。
由于ThreadGroup存储了线程和子线程组对象,可以使用ThreadGroup对一组线程执行统一的操作,比如interrupt.
可以参考Java API Doc知道更多关于ThreadGroup的方法。
分享到:
相关推荐
由浅入深——Java 2自学教程 配书光盘.rar 包含所有工程素材和源码
《由浅入深学JAVA》是本人自行编写的CHM格式的java基本教程,内容包括基本概念,JAVA的编译运行环境,类和接口,图形界面和文件操作等,概念和方法都有例程,都是在机器上通过的。附录中介绍JAVA的网络资源。是初雪...
完整版java基础入门教程由浅入深讲解 Java语言编程基础 第13章 多线程(共50页).ppt 完整版java基础入门教程由浅入深讲解 Java语言编程基础 第14章 网络通信(共76页).ppt 完整版java基础入门教程由浅入深讲解 ...
Java线程,主要讲述Java中关于线程的重点,难点。由浅入深,让我们更能够很快的理解并掌握线程知识。
由浅入深学Java—基础、进阶与必做260题.pdf
由浅入深学Java—基础、进阶与必做260题.pdf 由浅入深学Java—基础、进阶与必做260题.pdf
《由浅入深学Java:基础、进阶与必做260题》共分为4篇共28章,第1篇从最基本的JDK安装讲起,包括基本语法与数据类型、数组、字符串、程序控制语句、面向对象编程、继承、多态、接口等内容;第2篇讲解了图形界面开发...
深入 介绍线程知识,希望对大家有用,由浅入深
由浅入深学Java教程。 由浅入深学Java(一本java入门教材)
一本很好的软件书哦!
非常好的介绍VC多线程,由浅入深的给出了多个VC多线程例子,非常适合初学者
java多线程编程源码范例和详细说明(由浅入深,深度解读在资料后半部分)
由浅入深学Java—基础、进阶与必做260题高清版
内含java方面的知识,如:java语法基础,JDK5新特性,面向对象概述,面向对象程序设计,数据库,类的高级特征,数据结构与算法,网络,高级IO流等···是一套完整java教材。希望给大家带去帮助。 谢谢
Javase+OOAD+XML+JavaWeb+Junit+ant+Struts+Hibernate+Spring,适合新手入门级教程。
对多线程进行了由浅入深的讲解,有丰富的实例让初学者更容易上手
该文件中的java习题包含了java中几乎所有的知识点,大家尽管去分享吧,祝大家学习愉快。
Java面试宝典,从最基础的javaSE到Javaweb、设计模式、jvm基础知识、linux、前端框架、mysql和oracle数据库。 框架部分:spring框架、springMVC、shiro、Mybatis、struts2 技术:redis、消息队列ActiveMq、dubbo框架...