test.java

java定时器

import java.util.concurrent.PriorityBlockingQueue;
public class Test implements Runnable {
  PriorityBlockingQueue<TimeSlot> queue=
	  new PriorityBlockQueue<TimeSlot>(2048);
  
  
  public synchronized Object setTimer(String taskname, String eventname, int timerevent, int delay, Object param)...{
      TimerSlot slot = new TimerSlot();
      slot.taskname = taskname;
      slot.eventname = eventname;
      slot.timerevent = timerevent;
      slot.expiretime = System.currentTimeMillis() + delay;
      slot.param = param;
      try{
          queue_.put(slot);
      } catch (Exception ex){
      }
      return 0;
  }

  protected synchronized int killTimer(Object timer){
      if (queue_.remove(timer)){
          return 0;
      }
      return -1;
  }

	public void run() {
	
		
	}
   
}