cleandeadconnect.java

flash源码.fla和as文件

class CleanDeadConnect extends Thread
{
    Server s;
    ClientThread temp;
    String m;
    
    public CleanDeadConnect(Server  s)
    {
        this.s=s;
    }
    
    public void run()
    {
        while(true)
        {
            try
            {
                Thread.sleep(2600);
            }
            catch(InterruptedException e){;}
            
            synchronized(s.Clients)
            {
                //System.out.println("cle");
                for(int i=0;i<s.Clients.size();i++)
                {
                    temp=(ClientThread)s.Clients.elementAt(i);
                    if(!temp.isAlive())//zhongduan
                    {
                        ClientThread.ConnectNumber--;
                        
                        System.out.println("total number:"+ClientThread.ConnectNumber);
                        
                        m=temp.getClientAddress()+",:has quit"+ClientThread.ConnectNumber;
                        //m=m+ClientThread.ConnectNumber;
                        synchronized(s.messages)
                        {
                            s.messages.addElement(m);
                        }
                        s.Clients.removeElementAt(i);
                    }
                    else
                        System.out.println(temp+"runing !!!!!!!!!!!!!!!!!!!!!!");
                }
            }
        }
    }
}