【知识碎片】记录定时线程池ScheduledThreadPoolExecutor出现停止调度的问题

发布时间:2024年01月17日


问题记录

根据特定的业务场景,我首先创建了一个定时调度的线程池,每隔两秒会执行任务,那么这个任务又会创建一个非定时线程池,这个线程池会执行五次任务,那么!!!!
1、看下面代码,15行有代码抛异常的情况下定时调度的线程池会持续地去每隔2s去执行任务么?为什么
答:不会,当定时线程池执行的任务过程中出现异常没有捕获,会中断后续的任务,那么接下来的任务调度也不会执行,也就是说后续不会再打印 “主线程执行了”

1 public static void main(String[] args) {
2        Executors.newSingleThreadScheduledExecutor(new CustomThreadFactory("test")).scheduleWithFixedDelay(() -> {
3            ExecutorService executorService = Executors.newFixedThreadPool(2,new CustomThreadFactory("test"));
4            for(int i = 0;i<5;i++){
5                int finalI = i;
6                executorService.execute(new Runnable() {
7                    @Override
8                    public void run() {
9                        System.out.println(Thread.currentThread().getName()+1/(finalI -3));
10                    }
11               });
12            }
13            try {
14				//模拟抛异常代码
15                int a = 2/0 
16                System.out.println("主线程执行了");
17            } catch (InterruptedException e) {
18                throw new RuntimeException(e);
19            }
20        },0,2000, TimeUnit.MILLISECONDS);
21    }

2、如果去掉第14行代码和第15行代码,定时调度的线程池是否会持续地去每隔2s去执行任务么?为什么
答:会,当i=3时,因为第10行他是在创建的子线程抛异常的,不会影响外边定时任务线程的执行,他依旧会继续调度

1 public static void main(String[] args) {
2        Executors.newSingleThreadScheduledExecutor(new CustomThreadFactory("test")).scheduleWithFixedDelay(() -> {
4            ExecutorService executorService = Executors.newFixedThreadPool(2,new CustomThreadFactory("test"));
5            for(int i = 0;i<5;i++){
6                int finalI = i;
7                executorService.execute(new Runnable() {
8                    @Override
9                    public void run() {
10                          int a = 2/(i-3)
11                       System.out.println(Thread.currentThread().getName()+1/(finalI -3));
12                    }
13               });
14            }
15            try {
16                System.out.println("主线程执行了");
17            } catch (InterruptedException e) {
18                throw new RuntimeException(e);
19            }
20        },0,2000, TimeUnit.MILLISECONDS);
21    }

总结

定时任务线程池如果是由线程A执行调度的,如果线程A出现异常,那么会影响到后续的任务调度,后边的任务也会不执行,如果线程A创建了线程池子线程BCDE,在子线程中出现了异常不会影响定时任务的正常执行,

??如果有问题欢迎大家指正,讨论!!!!!!

文章来源:https://blog.csdn.net/weixin_47142014/article/details/135551977
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。