controlwindowprocessthread.java

中国联通短信通信协议

package com.wireless.sms.gwif.smsagent.workthread;

/**
 * <p>Title: WVAS-PLATFORM-SMS</p>
 * <p>Description: 无线增值业务平台-----短信接口机</p>
 * <p>Copyright: Copyright (c) 2003</p>
 * <p>Company: moon</p>
 * @author: tech team
 * @version 1.0
 */

//import org.apache.log4j.Logger;
//import java.io.*;
import java.util.*;

import com.wireless.sms.gwif.smsagent.global.LoggerConstant;
import com.wireless.sms.gwif.smsagent.global.SmsGWIFGlobal;

public class ControlwindowProcessThread {

    private ControlWindow controlwindow = ControlWindow.getInstance();
    private int waitTime = SmsGWIFGlobal.waitTime;
    private Timer timer = null;
    private static final ControlwindowProcessThread _instance = new ControlwindowProcessThread();

    public static ControlwindowProcessThread getInstance(){
        return _instance;
    }

    private ControlwindowProcessThread() {
    }

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

    public void start() {
    	LoggerConstant.stat_log.info("启动滑动窗口线程....");
        if( timer == null ){
            timer = new Timer(true);
            timer.schedule(new TimerTask(){
                public void run(){
                    if (controlwindow.size() > 0) {
                        controlwindow.get("" + 999999, true);
                    }
                }
            }, (waitTime*1000)/2, (waitTime*1000)/2);
        }
    }
}