connectkeeptimer.java

游戏说明

package com.tianxia.qipai.model.socket;

import java.util.TimerTask;

public class ConnectKeepTimer implements Runnable {
	private SocketManager sm;
	private boolean exitflag;
	private boolean runflag;
	private long recent;
	public ConnectKeepTimer(SocketManager sm) {
		super();
		this.sm = sm;
		exitflag = false;
		runflag = true;
		// TODO 自动生成构造函数存根
	}
	
	public void ToExit(){
		exitflag = true;
	}
	
	public void setRunflag(boolean runflag){
		this.runflag = runflag;
		
	}

	public void run() {
		while(true){
			if(exitflag){
				break;
			}
			if(runflag){
				if(System.currentTimeMillis()-recent>=1000){
					sm.ConnectKeep();
					recent = System.currentTimeMillis();
				}else{
					try {
						Thread.sleep(100);
					} catch (InterruptedException e) {
						// TODO 自动生成 catch 块
						e.printStackTrace();
					}
				}
			}else{
				try {
					Thread.sleep(1000);
				} catch (InterruptedException e) {
					// TODO 自动生成 catch 块
					e.printStackTrace();
				}
			}
				
		}
		
		
	}
	
	

}