broadcast.java

java聊天室服务器

package XXRoom;

import java.net.*;
import java.io.*;

/*负责广播消息队列里的消息*/
class Broadcast extends Thread
{
	ServerThread sThread;	
	
	public Broadcast( ServerThread sThread )
	{
		this.sThread = sThread;
	}

	public void run()
	{
		while( true )
		{
			try
			{
				Thread.sleep( 100 );
				
				String s;
				synchronized( sThread.messages )
				{
					if( sThread.messages.size() == 0 )
						continue;

					s = (String)sThread.messages.get( 0 );
					sThread.messages.remove( 0 );
				}
				synchronized( sThread.clients )
				{
					for( int i = 0; i < sThread.clients.size(); i ++ )
					{
						ClientThread cThread = (ClientThread)sThread.clients.get( i );
						if( cThread.ready == true )
							cThread.write.println( s );
					}					
				}
			}
			catch ( InterruptedException e )
			{
				e.printStackTrace();
			}
		}
	}

	public void dispose()
	{
		sThread = null;
	}
}