timeraction.java

用java 实现的一个任务管理器

package com.fang.server.schedule;

import java.util.Date;
import java.util.Timer;

import com.fang.common.core.FTask;
import com.fang.common.core.StatusChangeEvent;
import com.fang.server.net.ConfigListener;
import com.fang.server.net.TaskSetSender;


public class TimerAction implements Runnable {

	private Timer timer;
	FTaskArray taskarray;
	public TimerAction(){
		timer=new Timer();
		taskarray=FTaskArray.getInstance();
		
		new Thread(this).start();
	}
	
	public void run() {
        FTask itask;
		
		for(int i=0;i<taskarray.getTask_Vector().size();i++){
			itask=taskarray.getTask_Vector().get(i);
			System.out.println("rrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr");
        	System.out.println(itask.getInternal());
           if(itask.getStatus()==StatusChangeEvent.NOT_START){
			    TaskThread taskthread=new TaskThread(itask);
		        if(itask.getInternal()==0){
		        	
		        		 timer.schedule(taskthread, new Date(itask.getStarttime()));
		        }
		        else 
		        	{
			        timer.schedule(taskthread, new Date(itask.getStarttime()),itask.getInternal()*1000);
		        	}
           }
           }
	}
	
	public static void main(String[] args) {
		 new TaskSetSender();
         new TimerAction();
         new ConfigListener();
	}

}