package cn.std.test;

import java.util.Observable;

import cn.std.util.DateUtil;

public class RunThread extends Observableimplements Runnable{

  // 此方法一經(jīng)調(diào)用，立馬可以通知觀察者，在本例中是監(jiān)聽線程

  publicvoid doBusiness(){

    if(true){

      super.setChanged();

    }

    notifyObservers();

  }

  @Override

  publicvoid run() {

    intc = 0;

    while(true){  //模擬線程運(yùn)行一段時(shí)間之后退出

      System.out.println("Runing- "+c+" "+DateUtil.getStdDateTime());

      try{

        Thread.sleep(2000);

      }catch (InterruptedException e) {

        e.printStackTrace();

        doBusiness();

        break;

      }

      c++;

      //模擬拋出異常

      try{

        if(c== 4){

          Stringstr = null;

          str.length();//此處將會(huì)拋出空指針異常

        }

      }catch (Exception e) {

        e.printStackTrace();

        doBusiness();//在拋出異常時(shí)調(diào)用，通知觀察者，讓其重啟線程

        break;//異常拋出之后，一定要跳出循環(huán)，保證將線程送進(jìn)地獄

      }

    }  

  }

  publicstatic void main(String[] args) {

    RunThreadrun = new RunThread();

    Listener listen = new Listener();

    un.addObserver(listen);

    newThread(run).start();

    //run.doBusiness();

  }

}

package cn.std.test;

import java.util.Observable;

import java.util.Observer;

public class Listener implements Observer{

  @Override

  publicvoid update(Observable o, Object arg) {

    System.out.println("RunThread死機(jī)");

    RunThreadrun = new RunThread();

    run.addObserver(this);

    newThread(run).start();

    System.out.println("RunThread重啟");

  }

}