基于Java线程实现后台定时监控
http://tailsherry.javaeye.com/blog/176152
熟悉编写JavaScript的人，都习惯在页面写入setTimeOut来实现web页面的定时监控或事务处理。但是如何在Java服务端来实现这样一个监控机制呢？一般大家都会想到线程。但是一直以来，都没有亲身动手实践过。趁着工作间隙，自己也搬出一段代码来，与大家一起分享线程编程的神奇魔力。
首先创建一个基本抽象类SchedThread，代码内容如下：
view plaincopy to clipboardprint?
package com.test;
/**
* 基于Java线程实现后台定时监控 <P> Created: Mar 26, 2008 10:08:43 </P><P>
* </P><H4>http://tailsherry.javaeye.com</H4>
* <P>
*
* @author TailSherry
*/
public abstract class SchedThread
{
protected static final long NEVER = Long.MAX_VALUE;
// 定义一个线程锁，保证当前只有一个工作在操作中
private final Object lock = new Object();
// 定义一个Thread变量
private Thread thread;
// 控制线程循环的开关
private boolean active = true;
// 定义一个毫秒级的时间变量，指示何时执行下一个操作
private long nextTime;
/**
* 定义个一个抽象的方法用来获取下一个执行操作的时间，可使用NEVER
*/
protected abstract long getNextTime();
/**
* 定义一个抽象的方法，让子类来定义具体的工作过程
*/
protected abstract void executeWork();
protected String getName()
{
return getClass().getName();
}
/**
* 启动线程
*/
public void start()
{
thread = new Thread(new Runnable()
{
public void run()
{
runInternal();
}
}, getName());
thread.start();
}
/**
* 强迫停止线程，跳出for循环
*/
public void stop() throws InterruptedException
{
synchronized (lock)
{
active = false;
lock.notify();
}
thread.join();
}
/**
* 此方法可以在任何时候激活当前线程，让线程进入工作执行环节
*/
public void workAdded(long time)
{
synchronized (lock)
{
if (time < nextTime)
{
// 立刻激活线程工作继续运行
lock.notify();
}
}
}
/**
* 线程监测控制逻辑部分
*/
private void runInternal()
{
// 无限循环
for (;;)
{
// 该过程忽略了所有的Exception，以保证线程不会因此而中断
try
{
synchronized (lock)
{
nextTime = getNextTime();
// 获得时间区间，即要等待的时间段
long interval = nextTime - System.currentTimeMillis();
if (interval > 0)
{
try
{
lock.wait(interval);
}
catch (InterruptedException e)
{
// 忽略此Exception
}
}
// 如果active为false，强制中断
if (!active)
{
break;
}
}
// 执行具体的工作
executeWork();
}
catch (Throwable t)
{
try
{
Thread.sleep(10000);
}
catch (InterruptedException ie)
{
// 忽略此Exception
}
}
}
}
}</P>
package com.test;
/**
* 基于Java线程实现后台定时监控 Created: Mar 26, 2008 10:08:43
* http://tailsherry.javaeye.com
*
*
* @author TailSherry
*/
public abstract class SchedThread
{
protected static final long NEVER = Long.MAX_VALUE;
// 定义一个线程锁，保证当前只有一个工作在操作中
private final Object lock = new Object();
// 定义一个Thread变量
private Thread thread;
// 控制线程循环的开关
private boolean active = true;
// 定义一个毫秒级的时间变量，指示何时执行下一个操作
private long nextTime;
/**
* 定义个一个抽象的方法用来获取下一个执行操作的时间，可使用NEVER
*/
protected abstract long getNextTime();
/**
* 定义一个抽象的方法，让子类来定义具体的工作过程
*/
protected abstract void executeWork();
protected String getName()
{
return getClass().getName();
}
/**
* 启动线程
*/
public void start()
{
thread = new Thread(new Runnable()
{
public void run()
{
runInternal();
}
}, getName());
thread.start();
}
/**
* 强迫停止线程，跳出for循环
*/
public void stop() throws InterruptedException
{
synchronized (lock)
{
active = false;
lock.notify();
}
thread.join();
}
/**
* 此方法可以在任何时候激活当前线程，让线程进入工作执行环节
*/
public void workAdded(long time)
{
synchronized (lock)
{
if (time < nextTime)
{
// 立刻激活线程工作继续运行
lock.notify();
}
}
}
/**
* 线程监测控制逻辑部分
*/
private void runInternal()
{
// 无限循环
for (;;)
{
// 该过程忽略了所有的Exception，以保证线程不会因此而中断
try
{
synchronized (lock)
{
nextTime = getNextTime();
// 获得时间区间，即要等待的时间段
long interval = nextTime - System.currentTimeMillis();
if (interval > 0)
{
try
{
lock.wait(interval);
}
catch (InterruptedException e)
{
// 忽略此Exception
}
}
// 如果active为false，强制中断
if (!active)
{
break;
}
}
// 执行具体的工作
executeWork();
}
catch (Throwable t)
{
try
{
Thread.sleep(10000);
}
catch (InterruptedException ie)
{
// 忽略此Exception
}
}
}
}
}
以上这个类非常关键，基本上已经实现了所有的控制逻辑，如此再扩展出一个实现类出来，比如这里我写了一个模拟实现类MyDataGenerator，大家可以参考一下：
Java代码 view plaincopy to clipboardprint?
view plaincopy to clipboardprint?
package com.test;
public class MyDataGenerator extends SchedThread {
protected void executeWork() {
System.out.println("Execute work ...");
}
protected long getNextTime() {
return System.currentTimeMillis() + 2000L;
}
public static void main(String argv[]) {
MyDataGenerator generator = new MyDataGenerator();
generator.start();
}
}
package com.test;
public class MyDataGenerator extends SchedThread {
protected void executeWork() {
System.out.println("Execute work ...");
}
protected long getNextTime() {
return System.currentTimeMillis() + 2000L;
}
public static void main(String argv[]) {
MyDataGenerator generator = new MyDataGenerator();
generator.start();
}
}
当然这里没有使用workAdded和stop等功能，可以留给大家扩展。
