Java并发-UncaughtExceptionHandler捕获线程异常信息并重新启动线程

public class Testun { public static void main(String[] args) throws InterruptedException { Thread thread=new TaskThread(1);
thread.setName("thread-数据同步线程");
thread.start();
}
} class TaskThread extends Thread {
private int taskNum; public TaskThread(int num) {
this.taskNum = num;
}
@Override
public void run() {
//调用捕获异常，一定要放在要做逻辑的上面
Thread.currentThread().setUncaughtExceptionHandler(new MyExceptionHandler());
//todo int i=1/0;
}
} class MyExceptionHandler implements UncaughtExceptionHandler {
@Override
public void uncaughtException(Thread t, Throwable e) {
//1.打印报错日志
System.out.println("zzl异常信息: " + e.getMessage()); //2.重新启动线程
Thread[] threads = findAllThread(); //获取所有线程
for (Thread thread :threads){
if (thread.getName().trim().equalsIgnoreCase("thread-数据同步线程")){//校验线程是否正在运行
Thread thread1=new TaskThread(1);
thread1.setName("thread-数据同步线程");
thread1.start();//重新启动线程
}
}
}
//查询所有的线程
public Thread[] findAllThread(){
ThreadGroup currentGroup =Thread.currentThread().getThreadGroup(); while (currentGroup.getParent()!=null){
// 返回此线程组的父线程组
currentGroup=currentGroup.getParent();
}
//此线程组中活动线程的估计数
int noThreads = currentGroup.activeCount(); Thread[] lstThreads = new Thread[noThreads];
//把对此线程组中的所有活动子组的引用复制到指定数组中。
currentGroup.enumerate(lstThreads); for (Thread thread : lstThreads) {
System.out.println("线程数量："+noThreads+" 线程id：" + thread.getId() + " 线程名称：" + thread.getName() + " 线程状态：" + thread.getState());
}
return lstThreads;
}
}