Java Web应用启动间隔执行的程序

package Listeners;

import java.util.Timer;

import java.util.concurrent.Executors;

import javax.servlet.ServletContextEvent;

import javax.servlet.ServletContextListener;

import BackStage.MyTimerTask;

import Support.PoolManager;

public class StartupListener implements ServletContextListener {

@Override

public void contextDestroyed(ServletContextEvent sce) {

sce.getServletContext().log("定时器销毁");

}

@Override

public void contextInitialized(ServletContextEvent sce) {

sce.getServletContext().log("启动线程池");

// Start a thread pool to deal with different task;

PoolManager.pool = Executors.newFixedThreadPool(10);

sce.getServletContext().log("启动定时器");

//Create a Daemon timer thread

Timer timer=new Timer(true);

// 每隔10秒钟执行任务

timer.schedule(new MyTimerTask(sce.getServletContext()), 0,10 * 1000);

sce.getServletContext().log("已经添加任务调度表");

}

}

package BackStage;

import java.util.TimerTask;

import javax.servlet.ServletContext;

import Support.PoolManager;

public class MyTimerTask extends TimerTask {

private ServletContext context = null;

private int  param;

public MyTimerTask(ServletContext context) {

this.context = context;

}

@Override

public void run() {

context.log("开始执行指定定時任务");

// TODO 自定义

System.err.println("号称每10秒钟跑一次哦！我要调用线程池去执行另外的任务");

//让线程池去跑一个任务

PoolManager.pool.execute(new WorkThread(param++));

context.log("指定定時任务执行结束");

}

}

package Support;

import java.util.concurrent.ExecutorService;

public class PoolManager {

public static ExecutorService pool;

}

package BackStage;

public class WorkThread implements Runnable {

private int param;

public WorkThread(int param) {

this.param = param;

}

@Override

public void run() {

// TODO Do something

System.err.println("我被线程池调用执行啦~！参数：" + param);

}

}

<listener>

<listener-class>Listeners.StartupListener</listener-class>

</listener>