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>

以上这个类非常关键，基本上已经实现了所有的控制逻辑，如此再扩展出一个实现类出来，比如这里我写了一个模拟实现类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();

}

}