eventqueue.java

来自「一个MMORPG手机游戏的服务器端程序源代码」· Java 代码 · 共 48 行

package zsw_mmorpg.common;
import java.util.LinkedList;
import org.apache.log4j.Logger;
/**
 * EventQueue.java
 *
 * 事件队列
 *
 * @author <a href="mailto:[e-mail]">朱世伟</a>
 * @version 1.0
 */


/**事件队列*/
public class EventQueue {
    private Logger log;
    private LinkedList events;
    private int count = 0;

    public EventQueue (String name){
	log = Logger.getLogger("EventQueue: " + name);
	events = new LinkedList();
    }

    public synchronized void enQueue(GameEvent event) {
	//	log.debug("enQueue " + event.hashCode());
	events.addLast(event);
	notifyAll();
    }

    public synchronized GameEvent deQueue() throws InterruptedException {
	while (events.size() == 0) {
	    count++;
	    //	    log.debug("waiting, count: " + count);
	    wait();
	    count --;
	}

	GameEvent e = (GameEvent) events.removeFirst();
	//	log.debug("deQueue " + e.hashCode());
	return e;
    }

    public synchronized int size() {
	return events.size();
    }
}// EventQueue