cleandeadconnect.java

java scoket通信的源程序

public class CleanDeadConnect extends Thread      
{	//删除已死亡的连接的线程
	//声明ServerThread对象
    ServerThread serverThread;
    //声明ClientThread对象	
    ClientThread clietThread;
    String str;

    public CleanDeadConnect(ServerThread serverThread)
    {
        this.serverThread=serverThread;
    }

    public void run()
    {
        while(true)
        {
            try    //线程休眠300毫秒
            {
                Thread.sleep(10000);
            }
            catch(InterruptedException E){}
            //同步化serverThread.clients
            synchronized(serverThread.clients)
            {
                for(int i=0;i<serverThread.clients.size();i++)
                {
                	//获取存储的与客户端的连接
                    clietThread = (ClientThread) serverThread.clients.elementAt(i);
                    if(!clietThread.isAlive())
                    {
                    	//计数器减1
                        ClientThread.ConnectNumber--;
                        //从Vector数组中删除指定的与客户端的连接
                        serverThread.clients.removeElementAt(i);
                    }
                }
            }
        }
    }
}