一个需求：要实现能重启的线程。
背景：要启动一个线程，通过zmq，不断接收放过来的消息，在通知相应的用户。
假如这个时候网络不好或者其他问题，崩溃了，怎么办。当然，第一时间想到了try catch。
但是try catch没用啊。虽然没影响到项目的运行，但是这个线程报了异常之后就不会再执行了，这个订阅和通知功能就没有了。
所以要实现一个，崩溃了可以重新启动的线程了。
解决：用到了java自带的观察者模式。
被观察者抛出异常的时候，通知观察者。然后观察者直接给它重启就好了。也不存在观察者猝死的情况。
被观察者 Observable
public class RunThread extends Observableimplements Runnable{
// 此方法一经调用，立马可以通知观察者，在本例中是监听线程
publicvoid doBusiness(){
if(true){
super.setChanged();
}
notifyObservers();
}
@Override
publicvoid run() {
intc = 0;
while(true){ //模拟线程运行一段时间之后退出
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();//此处将会抛出空指针异常
}
}catch (Exception e) {
e.printStackTrace();
doBusiness();//在抛出异常时调用，通知观察者，让其重启线程
break;//异常抛出之后，一定要跳出循环，保证将线程送进地狱
}
}
}
publicstatic void main(String[] args) {
RunThreadrun = new RunThread();
Listener listen = new Listener();
un.addObserver(listen);
newThread(run).start();
//run.doBusiness();
}
}
观察者 Observer
public class Listener implements Observer{
@Override
publicvoid update(Observable o, Object arg) {
System.out.println("RunThread死机");
RunThreadrun = new RunThread();
run.addObserver(this);
newThread(run).start();
System.out.println("RunThread重启");
}
}