commandsender.java

贪吃蛇网络版 运行平台 LINUX/UNIX Macintosh Windows Server 2003 Windows 2000 Windows XP Windows CE Windows 9*/

package logic;
import java.util.*;

public class CommandSender implements Runnable {

	private Vector commandQueue = new Vector(); // 此向量为一个命令队列
	private SnakeServer ss;

	public CommandSender(SnakeServer ss) {

		this.ss = ss;
		new Thread(this).start();		
	}
	
	// 往命令队列添加新的命令
	public void add(String command) {
		commandQueue.insertElementAt(command,0);
	}
	
	public void run() {
	
		while (!Thread.interrupted()) {
			
			try	{
				// 如果队列中有新的命令
				if (commandQueue.size()>0) {
					// 就向所有玩家发送此命令
					ss.sendToAll((String)commandQueue.lastElement());
					// 再删除已发送过的命令
					commandQueue.removeElementAt(commandQueue.size()-1);
				}
				// 暂停一会，让出CPU资源给其他线程
				Thread.sleep(10);
			}catch (Exception e){
				e.printStackTrace();
			}			
		}
	}
};