熟悉编写JavaScript的人,都习惯在页面写入setTimeOut来实现web页面的定时监控或事务处理。但是如何在Java服务端来实现这样一个监控机制呢?一般大家都会想到线程。但是一直以来,都没有亲身动手实践过。趁着工作间隙,自己也搬出一段代码来,与大家一起分享线程编程的神奇魔力。
首先创建一个基本抽象类SchedThread,代码内容如下:
package com.test;
/**
* 基于Java线程实现后台定时监控 <p/> Created: Mar 26, 2008 10:08:43 <p/>
* <h4>http://tailsherry.iteye.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,大家可以参考一下:
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等功能,可以留给大家扩展。
分享到:
相关推荐
1. SpringBoot 自定义线程池以及多线程间的异步调用(@Async、@EnableAsync) 2.Java多线程之定时任务 以及 SpringBoot多线程实现定时任务 3.@EnableScheduling 与 @Scheduled
基于Java多线程与线程安全实践-基于Http协议的断点续传设计与实现.zip基于Java多线程与线程安全实践-基于Http协议的断点续传设计与实现.zip基于Java多线程与线程安全实践-基于Http协议的断点续传设计与实现.zip基于...
基于java多线程的一款小游戏基于java多线程的一款小游戏基于java多线程的一款小游戏 基于java多线程的一款小游戏基于java多线程的一款小游戏基于java多线程的一款小游戏 基于java多线程的一款小游戏基于java多线程的...
基于Java的多线程网络爬虫设计与实现.txt
讲解有关Java中多线程运行时针对单个线程的执行超时监控机制,用于处理单个线程执行控制
基于Java多线程实现所有顶点间最短路径的并行算法
有点乐趣,小java线程监控程序, 小java线程监控程序 小java线程监控程序
java一些简单的多线程用法,适合初学者
电子书相关:包含4个有关JAVA线程的电子书(几乎涵盖全部有关线程的书籍) OReilly.Java.Threads.3rd.Edition.Sep.2004.eBook-DDU Java Thread Programming (Sams) java线程第二版中英文 java线程第二版中英文 ...
Java线程讲解Java线程讲解Java线程讲解Java线程讲解Java线程讲解Java线程讲解Java线程讲解Java线程讲解Java线程讲解Java线程讲解
java多线程实现一个控制台聊天室 java多线程实现一个控制台聊天室
Java多线程实现异步调用实例。运行Main可以看到结果。main是主线程,另有A,B,C三个线程用不同的时间跑完。
java多线程模拟队列实现排队叫号,多线程模拟排队叫号取号 java多线程模拟队列实现排队叫号,多线程模拟排队叫号取号
java多线程实现TCP连接UDP聊天的聊天程序
Java线程Java线程Java线程Java线程Java线程Java线程Java线程Java线程Java线程Java线程Java线程Java线程Java线程Java线程Java线程
java多线程实现大批量数据切分成指定份数的数据,然后多线程处理入库或者导出,线程的个数和每份数据的数量都可以控制
Java线程Java线程Java线程Java线程Java线程Java线程
Java线程:概念与原理 Java线程:创建与启动 Java线程:线程栈模型与线程的变量 Java线程:线程状态的转换 Java线程:线程的同步与锁 Java线程:线程的交互 Java线程:线程的调度-休眠 Java线程:线程的调度-优先级 ...
本文档 描述怎样定时 启动一个线程任务 并加了注释 希望对你有帮助
基于java的开发源码-超简单Java多线程填表源码.zip 基于java的开发源码-超简单Java多线程填表源码.zip 基于java的开发源码-超简单Java多线程填表源码.zip 基于java的开发源码-超简单Java多线程填表源码.zip 基于java...