疯狂java


您现在的位置: 疯狂软件 >> 新闻资讯 >> 正文

Java线程run()方法中的异常


 

   

  run()与异常

  不管是Threade还是Runnable的run()方法都没有定义抛出异常,也就是说一条线程内部发生的checked异常,必须也只能在内部用try-catch处理掉,不能往外抛,因为线程是一个独立运行的代码片段,它的问题不能影响到其他线程

  如果run()内部抛出一个unchecked异常,这个线程可能会终止运行,这个异常也不能被主线程捕获,也影响不到其他线程的执行,比如下面的示例:

  package testpack;

  import java.io.IOException;

  public class Test2 {

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

  try {

  new A("异常线程").start();

  } catch(RuntimeException re) {

  System.out.println("主线程捕获到子线程的异常:"); //这里不会被执行,主线程不能捕获子线程的unchecked异常

  re.printStackTrace();

  }

  Thread.sleep(5);

  System.out.println("主线程照常执行"); //子线程终止,不影响主线程的正常执行

  }

  }

  class A extends Thread{

  A(String name){

  super(name);

  }

  public void run(){

  System.out.println("run()方法运行...");

  for (int i=0;i<10;i++) {

  System.out.println(getName()+" 输出:"+i);

  if (i==3) {

  throw new RuntimeException("run内部抛出Runtime异常"); //第3个循环时,抛出一个unchecked异常

  }

  }

  }

  }

  输出:

  run()方法运行...

  异常线程 输出:0

  异常线程 输出:1

  异常线程 输出:2

  异常线程 输出:3

  Exception in thread "异常线程" java.lang.RuntimeException: run内部抛出Runtime异常 at testpack.A.run(Test2.java:26) //子线程抛出unchecked异常,不能被主线程catch到,线程终止执行。这里的输出来源于ThreadGroup的uncaughtException()方法

  主线程照常执行 //子线程终止后,不影响主线程执行

  Thread.UncaughtExceptionHandler异常处理器

  Thread有一个静态内部接口,UncaughtExceptionHandler,该接口用来定义未处理异常处理器,只有一个方法void uncaughtException(Thread t,Throwable e)

  可以自己定义一个线程处理器,然后将其绑定到一个线程实例、Thread上,ThreadGroup已经实现了void uncaughtException(Thread t,Throwable e)方法,如果要更改的话,就继承ThreadGroup类然后重写该方法

  将一个未处理异常处理器绑到线程对象上:调用该线程对象的setUncaughtExceptionHandler()

  绑到Thread上:调用Thread的静态方法Thread.setDefaultUncaughtExceptionHandler()

  未处理异常处理器的调用顺序

  先找该线程实例是否有处理器

  再交给所属线程组的uncaughtException()方法

  严格的说,这个方法只是个中介,分下面三步走

  如果还有父线程组,则交给父线程组的uncaughtException()方法

  交给Thread的Thread.getDefaultUncaughtExceptionHandler()返回的Thread默认处理器

  最后看该线程是不是ThreadDeath对象,是的话,不做处理;不是的话,先用System.err输出哪个线程上有Exception,然后将异常跟踪站信息打印到System.err,线程结束

  看示例:

  package testpack;

  import java.lang.Thread.UncaughtExceptionHandler;

  public class Test2 {

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

  ExHandler eh1=new ExHandler("Thread默认异常处理器"); //定义一个异常处理器,后面绑到Thread上

  ExHandler eh2=new ExHandler("线程实例异常处理器"); //后面绑到线程实例上

  Thread.setDefaultUncaughtExceptionHandler(eh1); //将eh1处理器绑到Thread上

  A a=new A("异常线程");

  a.setUncaughtExceptionHandler(eh2); //标记㈠。将eh2绑到线程实例上

  a.start();

  }

  }

  class A extends Thread{

  A(ThreadGroup tg,String name){

  super(tg,name);

  }

  A(String name){

  super(name);

  }

  public void run(){

  System.out.println("run()方法运行...");

  for (int i=0;i<10;i++) {

  System.out.println(getName()+" 输出:"+i);

  if (i==3) {

  int x=5/0; //i==3时,抛出unchecked异常

  }

  }

  }

  }

  class ExHandler implements UncaughtExceptionHandler{ //自定义一个未处理异常处理器

  private String name;

  ExHandler(String name){

  this.name=name;

  }

  public void uncaughtException (Thread t,Throwable e){

  System.out.println("这是:"+name);

  System.out.println("线程: "+t.getName()+" 异常: "+e.getMessage());

  }

  }

  输出:

  run()方法运行...

  异常线程 输出:0

  异常线程 输出:1

  异常线程 输出:2

  异常线程 输出:3

  这是:线程实例异常处理器 //调用了线程实例上的异常处理器

  线程: 异常线程 异常: / by zero //程序结束

  将标记㈠处的代码注释掉,输出如下:

  run()方法运行...

  异常线程 输出:0

  异常线程 输出:1

  异常线程 输出:2

  异常线程 输出:3

  这是:Thread默认异常处理器 //调用了Thread上的默认处理器,“异常线程”属于main线程组,父线程组是system,

  线程: 异常线程 异常: / by zero