关于ScheduledExecutorService执行一段时间之后就不执行的问

93 阅读 0 评论 62 点赞

我是靠谱客的博主想人陪飞鸟，最近开发中收集的这篇文章主要介绍关于ScheduledExecutorService执行一段时间之后就不执行的问，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

最近写了个程序，程序中使用到了ScheduledExecutorService的scheduleAtFixedRate方法，用于定时执行任务，但是发现程序运行一段时间之后定时任务不执行了，查看日志和perfcounter都没有看到任何异常，比较郁闷。最后看了一下JDK的源码，在源码的Java doc中的发现了如下一句话：

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.
简单总结就是：如果定时任务执行过程中遇到发生异常，则后面的任务将不再执行。
我们可以做个实验验证一下：
先看下面一段代码：

/**
 *
[Copyright]
 *
@author
QiFuguang 
 *
Aug 25, 2014 9:48:41 PM	
 */
package com.winwill.xx;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class Test {

private final static ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();

public static void main(String[] args) {

scheduler.scheduleAtFixedRate(new Runnable() {

@Override

public void run() {

int[] s = new int[1];

System.out.println("OK");

System.out.println(s[1]);
// 数组越界

}

}, 0, 2, TimeUnit.SECONDS);

}
}

这段代码的执行效果如下:

关于scheduledexecutorservice执行一段时间之后不在执行的问题 - 黯然神伤 - winwill2014

可以看到定时任务只执行了一次，因为第一次执行就遇到了数组越界异常，后面的任务被取消了。

再看如下代码：

/**
 *
[Copyright]
 *
@author
QiFuguang 
 *
Aug 25, 2014 9:48:41 PM	
 */
package com.winwill.xx;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class Test {

private final static ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();

public static void main(String[] args) {

scheduler.scheduleAtFixedRate(new Runnable() {

@Override

public void run() {

try {

int[] s = new int[1];

System.out.println("OK");

System.out.println(s[1]); // 数组越界

} catch (Throwable t) {

System.out.println("Error");

}

}

}, 0, 2, TimeUnit.SECONDS);

}
}