messageproducer.java

来自「用jav语言开发的基于J2SE平台的中国象棋.供大家参考和学习」· Java 代码 · 共 28 行

package chinesechess.message.impl;

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

public class MessageProducer implements Producer{
	private MessageQueue queue;
	public MessageProducer(MessageQueue queue){
		this.queue=queue;
	}
	public void SetDestination(MessageQueue queue) {
		this.queue=queue;
	}

	public void send(Message msg){
		if(queue==null) {
			System.err.println("From MessageProducer:message queue is null!");
			return;
		}
		synchronized(queue){
			queue.putAMessage(msg);
			queue.notifyAll();
		}
	}

}