ScheduledExecutorService run方法要加入try catch

原文：http://www.andyqian.com/2018/03/07/java/javaSmallDetail/

前言

今天我们一起来做个简单有趣的实验。熟悉Java的童鞋，对ScheduledExecutorService类应该不陌生。不记得的童鞋，先回忆下。

实验一

我们先看下下面这段简单的代码。如下:

public class ExecutoryServiceTest {

        private static ScheduledExecutorService executorService = Executors.newScheduledThreadPool(10);

        public static void main(String[] args){
            executorService.scheduleAtFixedRate(new Runnable() {
                @Override
                public void run() {
                        int[] array  = new int[1];
                        System.out.println("<hello world>");
                        System.out.println(array[1]);
                }},0,2, TimeUnit.SECONDS);
            }
        }

够简单了吧。意思我就不再阐述了。看完别急，我们先回答下面这个问题：

问题一：

请问：上面一共打印了多少个hello world。

实验二

看到此处的童鞋，请在评论区给出你第一个实验的答案。紧接着，我们继续看第二个实验。

public class ExecutoryServiceTest {

        private static ScheduledExecutorService executorService = Executors.newScheduledThreadPool(10);

        public static void main(String[] args){
            executorService.scheduleAtFixedRate(new Runnable() {
                @Override
                public void run() {
                    try {
                        int[] array = new int[1];
                        System.out.println("<hello world>");
                        System.out.println(array[1]);
                    }catch(Exception ex){
                        ex.printStackTrace();
                    }
                }},0,2, TimeUnit.SECONDS);
            }
        }

问题二:

请问: 实验二中一共打印了多少个<hello world>。

请在评论区中给出你的答案。

分析

经过上述两个实验后，我们会发现两者的答案并不相同。这是为什么呢？因为在:run()方法中，发生异常后，中断了后续的执行。这是为什么呢？

其实呀，早在：scheduleAtFixedRate()JDK源码中就有这么一段描述:

If any execution of the task encounters an exception, subsequent executions are suppressed.Otherwise, the task will only terminate via cancellation or termination of the executor.

其意思就是告诉我们：如果任何执行任务遇到异常，其后续的操作会被压制。

同样的，在scheduleWithFixedDelay()方法中也有同样的描述。

一点点建议

在使用scheduleAtFixedRate()或scheduleWithFixedDelay()时，run()方法均要在使用try{}catch处理。避免出现定时任务执行若干次后不执行的”怪现象”。
我们平时在写系统时，无论是使用JDK自带函数，还是对接外部服务。使用时，一定要了解其使用方法。对入参，结果等都充分理解。(不瞒你说，我就出现过很多次没理解充分。导致Bug产生)。
强烈建议大家都在本机上运行下上面这实验的代码。这样有利于加深影响。

巴特西

ScheduledExecutorService run方法要加入try catch

前言

实验一

问题一：

实验二

问题二:

分析

一点点建议

最新文章

热门文章