dispatchthread.java

一个仿qq的程序源码 一个用纯java开发的

package qianqian.p2pchat.control;

import qianqian.p2pchat.constant.Const;
import qianqian.p2pchat.message.SystemMessage;

//分发消息线程
public class DispatchThread extends Thread {
	private Room chatroom = null;

	public DispatchThread(Room iRoom) {
		chatroom = iRoom;
	}

	public void run() {
		Controller controller = Controller.getInstance();
		while (!isInterrupted()) {
			SystemMessage advMsg = new SystemMessage(controller.getMe(),
					Const.CODE_ROOM_DISP, chatroom.getName());
			controller.getDispatcher().dispatchToAll(advMsg);
			try {
				Thread.sleep(Const.WaitTimeAdv);
			} catch (InterruptedException ex) {
				interrupt();
			}
		}
	}
}