当前位置：首页 > article >正文

java-重启异常断掉的线程和监控线程状态

article 2024/9/27 5:41:35

java-重启异常断掉的线程和监控线程状态

- 背景
- 主要代码
- 打印结果
- 总结

背景

有一个线程，可能会因为异常而终止掉。为了监控这个线程，我又启动一个线程去监控。

主要代码

代码主要是由两个线程和两个可以产生异常的方法，内容跟简单，如下

import java.time.LocalDateTime;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public class threadd {

    public static void main(String[] args) {
        Runnable runnable = new Runnable() {
            @Override
            public void run() {
                int i = 0;
                while (true) {
                    i++;
                    try {
                        Thread.sleep(1000);

                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    } catch (Exception e) {
                        e.printStackTrace();
                    }

                    if (i == 10) {
                        writeSth1();
                    }
                    System.out.println(LocalDateTime.now()+" "+i);
                }
            }
        };

        final Thread[] thread = {new Thread(runnable,"main thread")};
        thread[0].start();

        new Thread(new Runnable() {
                @Override
                public void run () {
                    while (true) {
                        try {
                            Thread.sleep(1000);
                            System.out.println(thread[0].getState());
                            if (!thread[0].isAlive()) {
                                System.out.println(LocalDateTime.now()+" 5秒后重启");
                                Thread.sleep(5000);

                                thread[0] = new Thread(runnable);
                                thread[0].start();
                            }
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                }
            },"check thread").start();
    }

    public static void writeSth1  () {
        writeSth();
    }
    
    public static void writeSth() {
        System.out.println(9 / 0);
    }

}

打印结果

从下面结果看，等i等于10的时候程序就会执行writeSth1 而产生异常，此时线程状态是TERMINATED，接着重启又继续跑10次，符合预期

RUNNABLE
2024-09-25T13:49:59.347 1
TIMED_WAITING
2024-09-25T13:50:00.354 2
TIMED_WAITING
2024-09-25T13:50:01.360 3
TIMED_WAITING
2024-09-25T13:50:02.366 4
TIMED_WAITING
2024-09-25T13:50:03.370 5
TIMED_WAITING
2024-09-25T13:50:04.374 6
TIMED_WAITING
2024-09-25T13:50:05.377 7
TIMED_WAITING
2024-09-25T13:50:06.380 8
TIMED_WAITING
2024-09-25T13:50:07.384 9
TIMED_WAITING
Exception in thread "main thread" java.lang.ArithmeticException: / by zero
	at threadd.writeSth(threadd.java:76)
	at threadd.writeSth1(threadd.java:73)
	at threadd$1.run(threadd.java:27)
	at java.lang.Thread.run(Thread.java:855)
TERMINATED
2024-09-25T13:50:09.346 5秒后重启
RUNNABLE
2024-09-25T13:50:15.361 1
RUNNABLE
2024-09-25T13:50:16.365 2
RUNNABLE
2024-09-25T13:50:17.368 3
RUNNABLE
2024-09-25T13:50:18.374 4
RUNNABLE
2024-09-25T13:50:19.377 5
RUNNABLE
2024-09-25T13:50:20.381 6
RUNNABLE
2024-09-25T13:50:21.387 7
RUNNABLE
2024-09-25T13:50:22.392 8
RUNNABLE
2024-09-25T13:50:23.395 9
RUNNABLE
Exception in thread "Thread-0" java.lang.ArithmeticException: / by zero
	at threadd.writeSth(threadd.java:76)
	at threadd.writeSth1(threadd.java:73)
	at threadd$1.run(threadd.java:27)
	at java.lang.Thread.run(Thread.java:855)
TERMINATED
2024-09-25T13:50:25.406 5秒后重启

总结

核心代码是先定义一个thread变量，然后有异常的时候又实例化重新赋值

  final Thread[] thread = {new Thread(runnable,"main thread")};
  thread[0].start();


 if (!thread[0].isAlive()) {
     System.out.println(LocalDateTime.now()+" 5秒后重启");
     Thread.sleep(5000);

     thread[0] = new Thread(runnable);
     thread[0].start();
 }

不能在检测到线程的时候直接thread.start()，因为线程的生命周期已经没有，需要重新实例化，如果使用如下代码就会报错

  final Thread[] thread = {new Thread(runnable,"main thread")};
  thread[0].start();


 if (!thread[0].isAlive()) {
     System.out.println(LocalDateTime.now()+" 5秒后重启");
     Thread.sleep(5000);
     
     thread[0].start();
 }