java 多线程——一个定时调度的例子

package com.scheduler; import java.io.BufferedReader;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException;
import java.util.ArrayList; /**
* 定时调度的小程序
* @ClassName: schedulerManager
* TODO
* @author Xingle
* @date 2014-8-5 下午5:24:37
*/
public class schedulerManager{
//调度列表,格式如下
//任务名|开始时间|间隔数量|间隔单位|程序URL地址
//其中间隔单位用以下表示：年 year,月 month,日 day,时 hour,分 min,秒 sec
public static ArrayList tls; public static void main(String[] args) {
tls = new ArrayList<>();
BufferedReader ins = null;
File f = new File("D:\\test/tasklist.txt");
try {
ins = new BufferedReader(new FileReader(f));
String line = "";
while ((line = ins.readLine()) != null) {
//增加一个是否执行标识，0 未执行
line = line+"|0";
String[] task = line.split("\\|");
tls.add(task);
}
ins.close();
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
} // 开启一个监视器
Monitor monitor = new Monitor();
monitor.start(); }
}

package com.scheduler; import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Date; /**
* 监视器</br>
* 1. 任务列表中,若任务时间到,则新开线程执行任务</br>
* 2. 对于单次调度,调度后标记移除</br>
* 3.对于循环调度,当前调度执行完移除，任务列表增加下次循环调度的任务</br>
* 4. 每次遍历休息1秒</br>
*
* @ClassName: Monitor
* @author Xingle
* @date 2014-8-5 下午5:25:01
*/
public class Monitor extends Thread { Monitor() {
} public void run() {
System.out.println("*** 监视器已启动,开始遍历监视任务列表 ***");
while (!schedulerManager.tls.isEmpty()) {
Date date = new Date();
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String currTime = sdf.format(date);
for (int i = 0; i < schedulerManager.tls.size(); i++) {
String[] task = (String[]) schedulerManager.tls.get(i);
// 任务起始时间
String sTime = task[1];
// 比较时间 ,开启一个子进程去执行任务
if (sTime.equals(currTime) && !task[5].equals("1")) {
execTask doTask = new execTask(task);
doTask.start();
// 已执行标示
task[5] = "1";
} // 循环调度的任务
if ((task[5].equals("1")) && (!task[2].equals("0"))) {
// 获取循环下次调用的任务
String[] nexttask = getNextTask(task);
schedulerManager.tls.add(nexttask);
System.out.println("**增加循环任务：" + nexttask[0] + " 下次调用时间："
+ nexttask[1] + " " + nexttask[4] + " 剩余："
+ schedulerManager.tls.size());
}
} System.out.println("当前时间：" + currTime);
for (int i = 0; i < schedulerManager.tls.size(); i++) {
String[] task = (String[]) schedulerManager.tls.get(i);
if (task[5].equals("1")) {
schedulerManager.tls.remove(i);
System.out.println("**减少任务：" + task[0] + " " + task[4]
+ " 剩余：" + schedulerManager.tls.size());
}
}
try {
sleep(1000);
} catch (Exception se) { }
} } /**
* 循环任务的下次调用任务情况
*
* @param task
* @return
* @author xingle
* @data 2014-8-5 下午6:34:25
*/
private String[] getNextTask(String[] task) {
// 下次调用时间
String[] nextTime = new String[6];
// 开始时间
String start = task[1];
// 间隔数量
int interval = new Integer(task[2]);
// 间隔单位
String unit = task[3];
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); Date sdate = new Date();
try {
sdate = sdf.parse(start);
} catch (ParseException e) {
e.printStackTrace();
} Calendar calendar = Calendar.getInstance();
calendar.setTime(sdate);
if (unit.equals("sec")) {
calendar.add(Calendar.SECOND, interval);
} else if (unit.equals("min")) {
calendar.add(Calendar.MINUTE, interval);
} else if (unit.equals("hour")) {
calendar.add(Calendar.HOUR, interval);
} else if (unit.equals("day")) {
calendar.add(Calendar.DAY_OF_MONTH, interval);
} else if (unit.equals("month")) {
calendar.add(Calendar.MONTH, interval);
} else if (unit.equals("year")) {
calendar.add(Calendar.YEAR, interval);
}
String next = sdf.format(calendar.getTime());
nextTime[0] = task[0];
nextTime[1] = next;
nextTime[2] = task[2];
nextTime[3] = task[3];
nextTime[4] = task[4];
nextTime[5] = "0";
return nextTime;
}
}

package com.scheduler; import java.io.IOException;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL; /**
* 执行任务</br>
* 访问指定网址
* @ClassName: execTask
*
* @author Xingle
* @date 2014-8-5 下午5:39:59
*/
public class execTask extends Thread{ String[] task =null; execTask(String[] task){
this.task = task;
}
public void run(){
try {
if(!openUrl(task[4])){
//写入错误日志文件
System.out.println("打开错误: "+task.toString());
}
} catch (IOException e) {
e.printStackTrace();
}
} /**
* 打开url
* @param inurl
* @return
* @author xingle
* @throws IOException
* @data 2014-8-5 下午7:02:30
*/
private boolean openUrl(String inurl) throws IOException{ URL url = null;
HttpURLConnection conn = null;
try {
url = new URL(inurl);
conn = (HttpURLConnection) url.openConnection();
} catch (MalformedURLException e) {
e.printStackTrace();
} catch (IOException e) {
System.out.println("***************** 连接失败,程序地址 : "+inurl);
e.printStackTrace();
return false;
}
if(conn.getResponseCode()!= HttpURLConnection.HTTP_OK){
System.out.println("****************** 调度失败!!,程序地址 : "+inurl);
return false;
}
else{
System.out.println("********************* 已完成调度，程序地址: "+inurl);
return true;
} } }