代码语言
.
CSharp
.
JS
Java
Asp.Net
C
MSSQL
PHP
Css
PLSQL
Python
Shell
EBS
ASP
Perl
ObjC
VB.Net
VBS
MYSQL
GO
Delphi
AS
DB2
Domino
Rails
ActionScript
Scala
代码分类
文件
系统
字符串
数据库
网络相关
图形/GUI
多媒体
算法
游戏
Jquery
Extjs
Android
HTML5
菜单
网页交互
WinForm
控件
企业应用
安全与加密
脚本/批处理
开放平台
其它
【
Java
】
可以配置定时任务的简单定时器
作者:
毛祥溢
/ 发布于
2013/7/19
/
551
package cn.maoxiangyi.task; import java.io.BufferedInputStream; import java.io.IOException; import java.lang.reflect.InvocationTargetException; import java.lang.reflect.Method; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.Date; import java.util.HashMap; import java.util.Map; import java.util.Map.Entry; import java.util.Properties; import java.util.Set; /** * 模块名称: 一个简单的定时器 功能点:读取项目根目录下的simpleTask.properties文件,并运行文件中配置的任务信息 * 版本:v0.02 * |--支持一次性任务,不支持周期性任务 * |--支持重新加载任务文件 待解决的问题: * 1:程序目前使用递归调用,比较消耗内存,后期要搞成循环的方式。 * * @author www.maoxiangyi.cn * */ public class SimpleTaskHandler { /* 任务类路径 */ private static String className; /* 定时器休眠时间 */ private static long sleepTime; /* 任务信息 */ private static Map<Long, String> taskMap; /* 是否重新加载配置文件 */ private static boolean isReload = false; static { load();// 加载任务配置文件 } /** * 启动定时器 */ public static void start() { try { doTask(); } catch (SecurityException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IllegalArgumentException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (ClassNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (NoSuchMethodException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IllegalAccessException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (InvocationTargetException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (InstantiationException e) { // TODO Auto-generated catch block e.printStackTrace(); } } /** * 执行下一个任务】 */ private static void getNextTask() { long time = nextTaskTime();// 获得将要执行任务的时间,即taskMap中的KEY if (time != 0) {// 如果时间符合要求,开始执行任务 configTaskInfo(time, taskMap.get(nextTaskTime()));// 使用time作为Key,获得任务Map中的任务类路径 } else { System.out.println("当前没有任务...."); } } /** * 配置当前要执行的任务信息 * * @param workTime * 任务执行的时间戳 * @param classDir * 任务类路径 */ private static void configTaskInfo(long workTime, String classDir) { sleepTime = workTime - System.currentTimeMillis();// 计算线程休眠的时间 className = classDir;// 将任务类路径赋值给成员变量 taskMap.remove(workTime);// 删除执行过的任务 } /** * 定时器 * * @throws InterruptedException * @throws SecurityException * @throws IllegalArgumentException * @throws ClassNotFoundException * @throws NoSuchMethodException * @throws IllegalAccessException * @throws InvocationTargetException * @throws InstantiationException */ private static void doTask() throws InterruptedException, SecurityException, IllegalArgumentException, ClassNotFoundException, NoSuchMethodException, IllegalAccessException, InvocationTargetException, InstantiationException { while (true) { // 线程开始休眠,休眠时间由即将要执行的任务时间-当前系统时间 Thread.sleep(sleepTime); // 如果要执行的任务的类路径不为空,开始执行任务 if (className != null) { run(); } // 任务执行完毕之后,将任务类路径置为空, //避免任务列表中的所有任务执行完毕之后,重复执行最后一个任务。 className = null; // 任务执行完毕之后,判断是否需要重新加载任务配置文件 if (isReload) { load(); } // 执行下一个任务 getNextTask(); } } /** * 下一个任务执行时间 1:获得当前系统时间 * 2:迭代任务列表中的所有任务,如果有任务大于当前时间,将任务时间记住。 * 迭代的过程中,保证被记住的任务时间永远是最小的。也就是即将要运行的任务时间。 * * @return */ private static Long nextTaskTime() { long currentTime = System.currentTimeMillis(); long nextTaskTime = 0; Set<Long> keySet = taskMap.keySet(); for (Long taskTime : keySet) { if (taskTime > currentTime) { if (taskTime < nextTaskTime || nextTaskTime == 0) { nextTaskTime = taskTime; } } } return nextTaskTime; } /** * 转换时间 转换simpleTask.properties文件中的KEY,Returns the number of milliseconds * * @param key * @return * @throws ParseException */ private static Long fomartTime(String key) { SimpleDateFormat simpleDateFormat = new SimpleDateFormat( "yyyy-MM-dd-HH-mm-ss"); Date date = null; try { date = simpleDateFormat.parse(key); } catch (ParseException e) { e.printStackTrace(); } return date.getTime(); } /** * 执行任务 1:使用反射技术获得任务的Class,该类必须要集成Thread线程类 * 2:获得要任务类的start()方法,创建一个任务类的实例,并运行 * * @throws ClassNotFoundException * @throws SecurityException * @throws NoSuchMethodException * @throws IllegalArgumentException * @throws IllegalAccessException * @throws InvocationTargetException * @throws InstantiationException */ @SuppressWarnings("unchecked") private static void run() throws ClassNotFoundException, SecurityException, NoSuchMethodException, IllegalArgumentException, IllegalAccessException, InvocationTargetException, InstantiationException { Class<? extends Thread> clazz = (Class<? extends Thread>) Class .forName(className); Method method = clazz.getMethod("start"); method.invoke(clazz.newInstance()); } /** * 避免立即加载配置文件引发的错误,在上一个任务执行完毕之后重新加载配置文件 */ public static void reload() { isReload = true; } /** * 读取任务配置文件 1:使用Properties对象加载项目根目录下的simpleTask.properties配置文件 * 2:转换加载后的键值对信息,将其中的Key转换成毫秒格式,并存放在任务map中。 * 3:加载完配置文件之后,将是否重新加载配置文件的标示标量置为false */ private static void load() { BufferedInputStream bif = new BufferedInputStream(Thread .currentThread().getContextClassLoader() .getResourceAsStream("simpleTask.properties")); Properties p = new Properties(); try { p.load(bif); Set<Entry<Object, Object>> entrySet = p.entrySet(); taskMap = new HashMap<Long, String>(); for (Entry<Object, Object> entry : entrySet) { String key = (String) entry.getKey(); String value = (String) entry.getValue(); taskMap.put(fomartTime(key), value); } p = null; bif.close(); isReload = false; } catch (IOException e) { e.printStackTrace(); } } public static void main(String[] args) throws Exception { SimpleTaskHandler.start();// 启动任务管理器 } }
试试其它关键字
简单定时器
同语言下
.
List 切割成几份 工具类
.
一行一行读取txt的内容
.
Java PDF转换成图片并输出给前台展示
.
java 多线程框架
.
double类型如果小数点后为零则显示整数否则保留两位小
.
将图片转换为Base64字符串公共类抽取
.
sqlParser 处理SQL(增删改查) 替换schema 用于多租户
.
JAVA 月份中的第几周处理 1-7属于第一周 依次类推 29-
.
java计算两个经纬度之间的距离
.
输入时间参数计算年龄
可能有用的
.
C#实现的html内容截取
.
List 切割成几份 工具类
.
SQL查询 多列合并成一行用逗号隔开
.
一行一行读取txt的内容
.
C#动态修改文件夹名称(FSO实现,不移动文件)
.
c# 移动文件或文件夹
.
c#图片添加水印
.
Java PDF转换成图片并输出给前台展示
.
网站后台修改图片尺寸代码
.
处理大图片在缩略图时的展示
毛祥溢
贡献的其它代码
(
2
)
.
ORA-01795: 列表中的最大表达式数为1000的解决方法详
.
可以配置定时任务的简单定时器
Copyright © 2004 - 2024 dezai.cn. All Rights Reserved
站长博客
粤ICP备13059550号-3