线程组
Java中的ThreadGroup类表示线程组,在创建新线程时,可以通过构造函数Thread(group...)来指定线程组。
线程组具有以下特征
如果没有显式指定线程组,则新线程属于默认线程组,默认情况下,与创建线程所在的组相同
一旦确定了线程所在线程组之后,不允许更改线程组,直到线程死亡
对于线程组ThreadGroup的一个对象,就表示一个线程组,线程组通过ThreadGroup(group...)来初始化,
线程组可以通过interrput(), setDamemon(),setMaxPriority()等方法来操作组内线程,通过activeCount(),isDamemon()来获取线程信息
下面是一个例子,
package threads; public class MyThread extends Thread {
public MyThread(String name) {
super(name);
} public MyThread(ThreadGroup group, String name) {
super(group,name);
} public void run() {
for (int i = 0; i<10; i++) {
System.out.println(getName() + " 线程的i变量 " + i);
}
}
}
package threads; public class ThreadGroupTest {
public static void main(String[] args) {
//获取主线程所在的线程组,这是所有线程默认的线程组
ThreadGroup mainGroup = Thread.currentThread().getThreadGroup();
System.out.println("主线程组的名字: "+mainGroup.getName());
System.out.println("主线程组是否为后台线程组: "+ mainGroup.isDaemon());
new MyThread("主线程组的线程").start();
ThreadGroup tg = new ThreadGroup("新线程组");
tg.setDaemon(true);
MyThread tt = new MyThread(tg, "tg线程组的线程甲");
tt.start();
new Thread(tg,"tg线程组的线程乙").start();
}
}
未处理异常
JAVA5之后,JVM会在线程抛出未处理异常后自动查找是否有对应的“未处理异常”处理对象,即Thread.UncaughtExceptionHandler对象,如果找到了该处理器对象,就会调用对象的uncaughtException来处理异常。
Thread提供了两个方法来自定义(未处理的)异常处理,
setDefaultUncaughtExceptionHandler(eh), 为线程类的所有实例设置默认的异常处理器
setUncaughtExceptionHandler(eh),为指定线程实例设置异常处理器
而在线程组中,因为ThreadGroup类也实现了Thread.UncaughtExceptionHandler接口,所以线程组会成为默认的异常处理器。
线程组处理异常的流程如下,
- 如果该线程组有父线程组,则调用父线程组的uncaughtException方法来处理异常
- 如果线程类有默认异常处理器,则用该异常处理器处理异常
- 如果异常对象不是ThreadDeath,就会打印异常信息,并结束该线程
下面演示一个例子,为主线程设置一个默认的异常处理器,当主程序抛出一个未处理异常时,该异常处理器将会起作用。
当一个线程抛出一个未处理异常时,JVM首先会查找该异常对应的异常处理器,
package threads; //自定义异常处理器,只需要实现Thread.UncaughtExceptionHandler接口
public class MyExHandler implements Thread.UncaughtExceptionHandler { //uncaughtException方法将处理线程中未处理的异常
@Override
public void uncaughtException(Thread t, Throwable e) {
// TODO Auto-generated method stub
System.out.println("自定义异常处理: "+ t + " 线程出现了异常 " + e);
}
}
package threads; public class ExHandler {
public static void main(String[] args) {
//设置主线程的默认异常处理器
Thread.currentThread().setUncaughtExceptionHandler(new MyExHandler());
int a = 5/0;
System.out.println("程序正常结束");
}
}
执行结果,可以看到程序虽然用自定义的异常处理器处理了一个未处理的异常,但还是没有正常结束程序,而是在处理完异常后直接结束了程序。
自定义异常处理: Thread[main,5,main] 线程出现了异常 java.lang.ArithmeticException: divide by zero
如果注释掉主程序中的第6行,让JVM来处理未处理的异常,执行结果如下,也是不能正常结束程序
Exception in thread "main" java.lang.ArithmeticException: divide by zero
at threads.ExHandler.main(ExHandler.java:7)
如果使用try catch finally来处理, 修改主程序如下,
package threads; public class ExHandler {
public static void main(String[] args) {
//设置主线程的默认异常处理器
//Thread.currentThread().setUncaughtExceptionHandler(new MyExHandler());
try {
int a = 5/0;
} catch (ArithmeticException e) {
e.printStackTrace();
} finally {
System.out.println("程序正常结束");
}
}
}
执行结果如下,可以看到这时候程序可以正常结束了,说明用try catch处理异常时,异常不会向上传给调用者
java.lang.ArithmeticException: divide by zero程序正常结束 at threads.ExHandler.main(ExHandler.java:8)
以下引用自 阿里巴巴Java开发手册
9. 【强制】多线程并行处理定时任务时,Timer运行多个TimeTask 时,只要其中之一没有捕获
抛出的异常,其它任务便会自动终止运行,使用ScheduledExecutorService则没有这个问题。