关于ScheduledExecutorService执行一段时间之后就不执行的问
2015-09-24 09:50
417 查看
最近写了个程序,程序中使用到了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);
}
}
这段代码的执行效果如下:
可以看到定时任务只执行了一次,因为第一次执行就遇到了数组越界异常,后面的任务被取消了。
再看如下代码:
/**
* [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);
}
}
运行效果如下:
加了try/catch之后可以看到定时任务没有被取消。
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);
}
}
这段代码的执行效果如下:
可以看到定时任务只执行了一次,因为第一次执行就遇到了数组越界异常,后面的任务被取消了。
再看如下代码:
/**
* [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);
}
}
运行效果如下:
加了try/catch之后可以看到定时任务没有被取消。
相关文章推荐
- 【傻傻分不清楚】C#抽象类和接口
- eclipse maven update project 相关问题
- Java String处理入门 - null或空值的判断处理
- 关于python脚本第一行#! /usr/bin/env python
- java.util.NoSuchElementException解决办法
- 2015 9月24日 工作计划与执行
- linux脚本:shell, 判断输入参数的个数(命令行)
- 体重档案应用客户端源码
- pop动画
- 汇编指令系统及其在单片机系统中的应用总结
- 通过窗口句柄获取窗口指针!
- JS实现网站菜单拖拽移位效果的方法
- BitNami一键安装Redmine
- 泛泰A820L (高通公司MSM8660 cpu) 3.4内核CM10.1(Android 4.2.2) 测试版第二版
- Java于 初始化序列?
- iptables 简单防火墙配置
- android 访问系统通讯录得到联系人数据
- Error:ERROR ITMS-90474: "Invalid Bundle. iPad Multitasking support requires these orientations:
- Docker在PHP项目开发环境中的应用
- 互联网创业必备工具盘点