java 多线程 目录：
学习了一段时间的多线程内容，项目中有个定时调度的需求，将之前的需求重新梳理了下，写了一个多线程调用的简单例子，加深学习。这块内容整理完，考虑单独弄一个系统，用线程池来完成，另把memcached也逐步放进来，目前系统已经基本搭建完毕。
定时调度的需求如下：设定任务的开始时间，分为单次调度和循环调度，访问指定的url。
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;
} } }
这里D:\test\tasklist.txt 中的文本如下：
task1|2014-08-06 11:42:00|5|sec|http://www.baidu.com
task2|2014-08-06 11:42:25|0|min|http://www.sina.com
task3|2014-08-06 19:00:00|3|min|http://www.cnblogs.com/xingele0917/
task4|2014-08-06 19:05:00|2|min|http://pomotodo.com/app/
task5|2014-08-06 18:09:00|1|min|http://www.w3school.com.cn/html5/
执行结果（截取一部分）：
*** 监视器已启动,开始遍历监视任务列表 ***
当前时间：2014-08-06 11:41:55
当前时间：2014-08-06 11:41:56
当前时间：2014-08-06 11:41:57
当前时间：2014-08-06 11:41:58
当前时间：2014-08-06 11:41:59
**增加循环任务：task1 下次调用时间：2014-08-06 11:42:05 http://www.baidu.com 剩余：6
当前时间：2014-08-06 11:42:00
**减少任务：task1 http://www.baidu.com 剩余：5
********************* 已完成调度，程序地址: http://www.baidu.com
当前时间：2014-08-06 11:42:01
当前时间：2014-08-06 11:42:02
当前时间：2014-08-06 11:42:03
当前时间：2014-08-06 11:42:04
**增加循环任务：task1 下次调用时间：2014-08-06 11:42:10 http://www.baidu.com 剩余：6
当前时间：2014-08-06 11:42:05
**减少任务：task1 http://www.baidu.com 剩余：5
********************* 已完成调度，程序地址: http://www.baidu.com
当前时间：2014-08-06 11:42:07
当前时间：2014-08-06 11:42:08
当前时间：2014-08-06 11:42:09
**增加循环任务：task1 下次调用时间：2014-08-06 11:42:15 http://www.baidu.com 剩余：6
当前时间：2014-08-06 11:42:10
**减少任务：task1 http://www.baidu.com 剩余：5
********************* 已完成调度，程序地址: http://www.baidu.com
当前时间：2014-08-06 11:42:11
当前时间：2014-08-06 11:42:12
当前时间：2014-08-06 11:42:13
当前时间：2014-08-06 11:42:14
**增加循环任务：task1 下次调用时间：2014-08-06 11:42:20 http://www.baidu.com 剩余：6
当前时间：2014-08-06 11:42:15
**减少任务：task1 http://www.baidu.com 剩余：5
********************* 已完成调度，程序地址: http://www.baidu.com
当前时间：2014-08-06 11:42:16
当前时间：2014-08-06 11:42:17
当前时间：2014-08-06 11:42:18
当前时间：2014-08-06 11:42:19
**增加循环任务：task1 下次调用时间：2014-08-06 11:42:25 http://www.baidu.com 剩余：6
当前时间：2014-08-06 11:42:20
**减少任务：task1 http://www.baidu.com 剩余：5
********************* 已完成调度，程序地址: http://www.baidu.com
当前时间：2014-08-06 11:42:21
当前时间：2014-08-06 11:42:22
当前时间：2014-08-06 11:42:23
当前时间：2014-08-06 11:42:24
**增加循环任务：task1 下次调用时间：2014-08-06 11:42:30 http://www.baidu.com 剩余：6
当前时间：2014-08-06 11:42:25
**减少任务：task2 http://www.sina.com 剩余：5
**减少任务：task1 http://www.baidu.com 剩余：4
********************* 已完成调度，程序地址: http://www.baidu.com
********************* 已完成调度，程序地址: http://www.sina.com
当前时间：2014-08-06 11:42:26
当前时间：2014-08-06 11:42:27
当前时间：2014-08-06 11:42:28
当前时间：2014-08-06 11:42:29
**增加循环任务：task1 下次调用时间：2014-08-06 11:42:35 http://www.baidu.com 剩余：5
当前时间：2014-08-06 11:42:30
**减少任务：task1 http://www.baidu.com 剩余：4
********************* 已完成调度，程序地址: http://www.baidu.com