首先看看我的定时器的代码:
public class CleanTimer{
private Timer timer;
/**
* Creates a new instance of CleanTimer
*/
public CleanTimer() {
}
public void StartService(Date delaytime, Long cycletime) {
try{
timer = new Timer();
timer.scheduleAtFixedRate(new CleanTimerTask(), delaytime, cycletime);
} catch(Exception ex) {
ex.printStackTrace();
}
}
}public class CleanTimerTask extends TimerTask {
/** Creates a new instance of CleanTimerTask */
public CleanTimerTask() {
}
public void run() {
try{
CleanTask.ExecuteCleanFunction();
} catch(Exception ex) {
ex.printStackTrace();
}
}
}
现在有个问题,我的任务是变的,有增有减,增加的时候,我可以new CleanTimer调用StartService()方法添加一个,但是当需要回收掉以前增加的某个TASK的时候,就不知道该怎么做了
Timer 和 TimerTask 都有cancel方法,但是怎么用呀,我怎么才能找到我要cancel掉的Task或者是Timer呢?
看Timer的API中,它的构造方法中有一个Timer(String name)的,说明写的是:创建一个新计时器,其相关的线程具有指定的名称。但是指定名称有说明用呀,我刚开始以为以后可以根据这个名称把所创建的Timer get出来,可以翻到后面的方法中,也没有说是能根据名称找出所创建的方法呀,请教高人,我该怎么做,先谢谢了!在线等!
public class CleanTimer{
private Timer timer;
/**
* Creates a new instance of CleanTimer
*/
public CleanTimer() {
}
public void StartService(Date delaytime, Long cycletime) {
try{
timer = new Timer();
timer.scheduleAtFixedRate(new CleanTimerTask(), delaytime, cycletime);
} catch(Exception ex) {
ex.printStackTrace();
}
}
}public class CleanTimerTask extends TimerTask {
/** Creates a new instance of CleanTimerTask */
public CleanTimerTask() {
}
public void run() {
try{
CleanTask.ExecuteCleanFunction();
} catch(Exception ex) {
ex.printStackTrace();
}
}
}
现在有个问题,我的任务是变的,有增有减,增加的时候,我可以new CleanTimer调用StartService()方法添加一个,但是当需要回收掉以前增加的某个TASK的时候,就不知道该怎么做了
Timer 和 TimerTask 都有cancel方法,但是怎么用呀,我怎么才能找到我要cancel掉的Task或者是Timer呢?
看Timer的API中,它的构造方法中有一个Timer(String name)的,说明写的是:创建一个新计时器,其相关的线程具有指定的名称。但是指定名称有说明用呀,我刚开始以为以后可以根据这个名称把所创建的Timer get出来,可以翻到后面的方法中,也没有说是能根据名称找出所创建的方法呀,请教高人,我该怎么做,先谢谢了!在线等!
private Timer timer; //这里有问题
//可改为:
//private List<Timer> timerList = new ArrayList<Timer>();
//在这个基础上,楼主再作相应的修改就可以了。
/**
* Creates a new instance of CleanTimer
*/
public CleanTimer() {
}
public void StartService(Date delaytime, Long cycletime) {
try{
timer = new Timer(); //这里有问题
//每次开始新的任务
//timer会被赋予新值
//原来的timer和它的TimerTask还有线程就无法终止了。
timer.scheduleAtFixedRate(new CleanTimerTask(), delaytime, cycletime);
} catch(Exception ex) {
ex.printStackTrace();
}
}
}
public class CleanTimer{
private static Map<String,Timer> mapTimer=new HashMap<String,Timer>();
/**
* Creates a new instance of CleanTimer
*/
public CleanTimer() {
}
public static void StartService(DctCleanTab dct,Date delaytime, Long cycletime) {
try{
mapTimer.put("T"+dct.getCdid().getCdid().toString(),new Timer());
CleanTimerTask ctt=new CleanTimerTask();
ctt.setDctParam(dct);
mapTimer.get("T"+dct.getCdid().getCdid().toString()).scheduleAtFixedRate(ctt, delaytime, cycletime);
DctLogger.info(dct.getTaskname()+"任务实例成功启动!");
} catch(Exception ex) {
ex.printStackTrace();
DctLogger.error(dct.getTaskname()+"任务实例启动失败:"+ex.getMessage(),ex.getCause());
}
}
public static void RemoveTimer(DctCleanTab dct){
try{
mapTimer.get("T"+dct.getCdid().getCdid().toString()).cancel();
mapTimer.remove("T"+dct.getCdid().getCdid().toString());
DctLogger.info(dct.getTaskname()+"任务实例停用成功!");
}catch(Exception e){
e.printStackTrace();
DctLogger.error(dct.getTaskname()+"任务实例停用失败:"+e.getMessage(),e.getCause());
}
}
}谢谢帮忙,但是你的意思我没有完全明白,你看下我写的代码,是不是这样的:public class CleanTimerTask extends TimerTask {
private DctCleanTab dctParam;
/** Creates a new instance of CleanTimerTask */
public CleanTimerTask() {
}
public void run() {
try{
ExecuteCleanBean.ExecuteCleanFunction(dctParam);
System.out.println("StrParam:"+dctParam.getTaskname()+new Date());
} catch(Exception ex) {
ex.printStackTrace();
}
} public DctCleanTab getDctParam() {
return dctParam;
} public void setDctParam(DctCleanTab dctParam) {
this.dctParam = dctParam;
}
}但是这样写,当我根据DctCleanTab对象来删除Timer时,也是不行的,我建立了两个DctCleanTab 对象,然后依次启动,启动后,在任务开始执行后,我调用CleanTimer.RemoveTimer(DctCleanTab dct)删除对应的两个定时器,但是,总是只能删掉其中一个。另外一个始终删不掉,好只能删掉后启动的定时器。另外一个始终在运行,晕了,本人水平有限呀,还需麻烦大虾帮忙看看...
private static Map<String,Timer> mapTimer=new HashMap<String,Timer>();
private CleanTimer() {
}
public static void StartService(String taskName) {
try{
mapTimer.put(taskName,new Timer());
CleanTimerTask ctt=new CleanTimerTask(taskName);
mapTimer.get(taskName).scheduleAtFixedRate(ctt, 0, 1000);
} catch(Exception ex) {
ex.printStackTrace();
}
}
public static void RemoveTimer(String taskName){
try{
mapTimer.get(taskName).cancel();
mapTimer.remove(taskName);
}catch(Exception e){
e.printStackTrace();
}
}
}
CleanTimerTask:public class CleanTimerTask extends TimerTask {
private String taskName;
public CleanTimerTask(String taskName) {
this.taskName = taskName;
}
public void run() {
System.out.println(taskName+" is running.");
}
}
主程序:public class CleanTimerDriver { public static void main(String[] args) throws InterruptedException {
CleanTimer.StartService("Task1");
CleanTimer.StartService("Task2");
Thread.sleep(3000);
CleanTimer.RemoveTimer("Task1");
CleanTimer.RemoveTimer("Task2"); }}
原:mapTimer.put("T"+dct.getCdid().getCdid().toString(),new Timer());
mapTimer.get("T"+dct.getCdid().getCdid().toString()).scheduleAtFixedRate(ctt, delaytime, cycletime);mapTimer.get("T"+dct.getCdid().getCdid().toString()).cancel();
mapTimer.remove("T"+dct.getCdid().getCdid().toString());更改:mapTimer.put("T"+dct.getCtid().toString(),new Timer());
mapTimer.get("T"+dct.getCtid().toString()).scheduleAtFixedRate(ctt, delaytime, cycletime);mapTimer.get("T"+dct.getCtid().toString()).cancel();
mapTimer.remove("T"+dct.getCtid().toString());