cleandeadconnect.java

java编写聊天室

public class CleanDeadConnect extends Thread{
	ServerThread sThread;
	ClientThread c;
	String m;
	public CleanDeadConnect(ServerThread s)
	{
		this.sThread=s;
	}
	public void run(){
		while(true){
			try{
				Thread.sleep(10000);
				}
			catch(InterruptedException e){
				
			}
			synchronized(sThread.Clients){
				for(int i=0;i<sThread.Clients.size();i++)
				{
					c=(ClientThread)sThread.Clients.elementAt(i);
					if(!c.isAlive())
					{
						ClientThread.ConnectNumber--;
						m=c.getClientName()+c.getClientAddress();
						m=m+"已经断开联接目前联机数："+ClientThread.ConnectNumber+"\n";
						sThread.frame.ServerStatus.append(m);
						//synchronized(sThread.messages)
						//{
							//sThread.messages.addElement(m);
						//}
						sThread.Clients.removeElementAt(i);
						sThread.username.removeElementAt(i);
						//c.Names.removeElementAt(i);
					}
				}
			}
		}
	}

}