crbtsendmonitor.java

中国联通炫铃业务接口开发

package com.wireless.crbt.gwif.workthread;

import java.util.Timer;
import java.util.TimerTask;

import com.wireless.crbt.gwif.global.GetCRBTGlobalForUsual;
import com.wireless.crbt.gwif.global.LoggerConstant;

public class CrbtSendMonitor {

  private static CrbtSendMonitor _instance = new CrbtSendMonitor();
  private Timer timer = null;
  public static final int COMPUTE = 18;
  private static int counter=0;

  public static CrbtSendMonitor getInstance(){
    return _instance;
  }

  public void start(){
      LoggerConstant.log.info("------启动监控线程");
    if( timer == null ){
      timer = new Timer(true);
      timer.schedule(new TimerTask() {
        public void run() {
        	if(GetCRBTGlobalForUsual.crbtqueue.size()>0)
        		counter++;
        	if(counter>COMPUTE){
        		CrbtClientController.restartAll();
        		counter=0;
        	}
        }
      }
      , 10000, 10000);
    }
  }

  public void stop(){
    if( timer != null ){
      timer.cancel();
      timer = null;
    }
  }

  public void setSendFlag(boolean sendFlag){

    if( sendFlag ){
      counter = 0;
    }
  }


}