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

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

操作方法

  • 01

    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 } } } } }

  • 02

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

  • 03

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

(0)

相关推荐

  • java线程池的使用

    大量的创建线程,会过度消耗计算机资源,对于比较简单的任务可以使用线程池,限制过度创建线程.Java中提供大量的线程池构类,类型多种多样,包括: (1) newCachedThreadPool (2) ...

  • JAVA线程安全:[1]浅谈JAVA内存模型

    关于java线程安全,网上有很多资料,我只想从自己的角度总结对这方面的考虑,有时候写东西是很痛苦的,知道一些东西,但想用文字说清楚,却不是那么容易.我认为要认识java线程安全,必须了解两个主要的点: ...

  • 基于3G/4G GPRS DTU数据监控系统方案

    3G/4G GPRS DTU是目前解决移动通信信息服务的一种较完美的业务,它是以数据流量计费.或大数据的包月包年计费.覆盖范围广泛.数据传输速度更快.3G/4G GPRS DTU的推出,为行业和企业用 ...

  • JAVA线程安全:[4]volatile关键字

    volatile是java提供的一种同步手段,只不过它是轻量级的同步,为什么这么说,因为volatile只能保证多线程的内存可见性,不能保证多线程的执行有序性.而最彻底的同步要保证有序性和可见性,例如 ...

  • java线程系列---Runnable和Thread的区别

    在java中可有两种方式实现多线程,一种是继承Thread类,一种是实现Runnable接口:Thread类是在java.lang包中定义的.一个类只要继承了Thread类同时覆写了本类中的run() ...

  • 【java新手教程】Spring 基于Java配置

    在实际业务开发过程中,我们应用到Spring去配置各种资源文件的集成到应用中很习以为常的做法,在Spring2.x发展到Spring3.x的过程中已经有很多的配置方式,这里我归纳总结一下,其中也包括了 ...

  • java守护线程

    java中根本没有单线程程序,就算开发人员只开发了主线程,后台还是有很多的辅助线程.,比如JVM的垃圾回收.内存管理等线程.后台运行的线程一般称为守护线程. 操作方法 01 守护线程与普通线程写法上基 ...

  • 常用的linux系统监控命令整理

    找到最耗CPU的java线程ps命令 命令:ps -mp pid -o THREAD,tid,time 或者 ps -Lfp pid 结果展示: 这个命令的作用,主要是可以获取到对应一个进程下的线程的 ...

  • 怎么监控自己的电脑

    有时因为一些特殊原因需要监控自己的电脑,如监控小孩使用电脑的过程,防止其访问一些不利于成长的网站,该怎么实现呢?我们可以通过在电脑上安装监控软件,然后通过在后台定时截屏及记录键盘输入的方式对电脑进行监 ...