eventqueue.java

利用java实现的多人游戏的服务器系统

package com.hypefiend.javagamebook.common;

import java.util.LinkedList;
import org.apache.log4j.Logger;

/**
 * EventQueue.java
 *
 * Blocking queue of GameEvents.
 *
 * @author <a href="mailto:[e-mail]">bret barker</a>
 * @version 1.0
 */
public class EventQueue {
    private Logger log;
    private LinkedList events;
    private int count = 0;

    /** 
     * Constructor.  Initializes the logger and event list
     */
    public EventQueue (String name){
	log = Logger.getLogger("EventQueue: " + name);
	events = new LinkedList();
    }
    
    /** 
     * add an event to the queue
     */
    public synchronized void enQueue(GameEvent event) {
	//	log.debug("enQueue " + event.hashCode());
	events.addLast(event);
	notifyAll();
    }

    /** 
     * blocks until an event is available 
     * and then removes and returns the first 
     * available event
     */
    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;
    }

    /**
     * get the current # of events in the queue
     */
    public synchronized int size() {
	return events.size();
    }

}// EventQueue