connectedmemberupdater.java

chat room

package Server;

import ShareData.Message;

public class ConnectedMemberUpdater implements Runnable{

	private long N;
	private Server server;
	private boolean conn=true;
	public void setConn(boolean b){
		conn=b;
	}
	public ConnectedMemberUpdater(long n,Server s){
		N=n;
		server=s;
	}
	
	synchronized public void sendUserListToClient(){
		try {
			Message m=new Message("list",server.getClientList());
			server.sendToAll(m);
			Thread.sleep(N*1000);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	
	@Override
	public void run() {
		// TODO Auto-generated method stub
		while(conn){
			sendUserListToClient();
		}
		
	}

}