monitorthread.java

java聊天室服务器

package XXRoom;

import java.util.List;
import java.util.ArrayList;

//监测死亡线程
class MonitorThread extends Thread
{
	List lt = new ArrayList();

	public void addClient( ClientThread ct ) {
		lt.add( ct );
	}

	public void run() {
		while( true ) {
			synchronized( lt ) {
					for( int i = 0; i < lt.size(); i ++ ) {
						((ClientThread)lt.get( i ) ).dispose();
					}
					lt.clear();
			}
			try
			{
				Thread.sleep( 500 );
			}
			catch ( InterruptedException e )
			{
			}
		}
	}		

	public void dispose () {		
		for( int i = 0; i < lt.size(); i ++ ) {
			((ClientThread)lt.get( i ) ).dispose();
		}
		lt.clear();		
	}	
};