cleandeadconnect.java

chatting room 程序

package SmallChatRoom;

public class CleanDeadConnect extends Thread {

	ServerThread sThread;
	ClientThread temp;
	String m;
	
	public CleanDeadConnect(ServerThread sThread){
		this.sThread=sThread;
	}
	
	public void run(){
		while(true){
			try{
				Thread.sleep(10000);
			}
			catch(InterruptedException e){}
			
			synchronized(sThread.clients)
			{
				for(int i=0;i<sThread.clients.size();i++)
				{
					temp=(ClientThread)sThread.clients.elementAt(i);
					
					if(!temp.isAlive()){
						ClientThread.connectNumber--;
					m=temp.getClientName()+":"+temp.getClientAddress();
					m=m+"已离开 目前在线用户数:"+ClientThread.connectNumber+"\n";
					sThread.sframe.serverstatus.append(m);
					synchronized(sThread.messages){
						sThread.messages.addElement(m);
					}
					sThread.clients.removeElementAt(i);
						
					}
				}
			}
		}
	}
}