基于Java线程实现后台定时监控

转载：http://littlefermat.blog.163.com/blog/static/59771167200928115047810/

熟悉编写JavaScript的人，都习惯在页面写入setTimeOut来实现web页面的定时监控或事务处理。但是如何在Java服务端来实现这样一个监控机制呢？一般大家都会想到线程。但是一直以来，都没有亲身动手实践过。趁着工作间隙，自己也搬出一段代码来，与大家一起分享线程编程的神奇魔力。

首先创建一个基本抽象类SchedThread，代码内容如下：

Java代码



package com.test;

/**

* 基于Java线程实现后台定时监控 <p/> Created: Mar 26, 2008 10:08:43 <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

}

}

}

}

}

package com.test;

/**
* 基于Java线程实现后台定时监控 <p/> Created: Mar 26, 2008 10:08:43 <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
}
}
}
}
}

以上这个类非常关键，基本上已经实现了所有的控制逻辑，如此再扩展出一个实现类出来，比如这里我写了一个模拟实现类MyDataGenerator，大家可以参考一下：

Java代码



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等功能，可以留给大家扩展。