chessmessagequeue.java

用jav语言开发的基于J2SE平台的中国象棋.供大家参考和学习

package chinesechess.message.impl;

import java.util.ArrayList;

import chinesechess.message.Message;
import chinesechess.message.MessageQueue;


public class ChessMessageQueue implements MessageQueue{
	private ArrayList msgQueue=new ArrayList();
	public synchronized Message getAMessage() {
		if(msgQueue.size()>0) return (Message) msgQueue.remove(0);
		return null;
	}

	public synchronized void putAMessage(Message msg) {
		msgQueue.add(msg);
	}

	public synchronized boolean isEmpty() {
		return msgQueue.size()==0;
	}
	public synchronized void removeAll(){
		msgQueue.clear();
	}
}