broadcost.java

chatting room 程序

package SmallChatRoom;

public class BroadCost extends Thread {

	ClientThread c;
	ServerThread sThread;
	String m;
	public BroadCost(ServerThread sThread)
	{
		this.sThread=sThread;
	}
	
	public void run(){
		while(true){
			try{
				Thread.sleep(1000);
			}
			catch(InterruptedException e){}
			
			synchronized(sThread.messages){
				if(sThread.messages.isEmpty())
					continue;
			    m=sThread.messages.firstElement().toString();
			    sThread.messages.removeElement(m);
			}
			
			synchronized(sThread.clients){
				for(int i=0;i<sThread.clients.size();i++)
				{
					c=(ClientThread)sThread.clients.elementAt(i);
					c.writer.println(m);
				}
			}
			
		}
	}
}