waitqueue.java

RFID复杂事件处理系统的研究实验

package test;

import java.util.LinkedList;

public class WaitQueue implements EventReceiver{
	
	private LinkedList<P_Event> queue=new LinkedList<P_Event>();
    private static int m=0;
	
	WaitQueue(){}
	

	public synchronized void acceptEvent(P_Event e)
	{
		queue.addLast(e);
		
		this.notify();
	}
	
	public synchronized P_Event getEvent()
	{
		try
		{
			if(queue.size()==0) 
			{
				this.wait();
			}			
		}
	    catch (InterruptedException e)
	    {
		    // TODO Auto-generated catch block
		    e.printStackTrace();
	    }
	    return queue.removeFirst();
	}
	
	public synchronized P_Event getEvent0()
	{
		try
		{
			if(queue.size()<=m) 
			{
				this.wait();
			}			
		}
	    catch (InterruptedException e)
	    {
		    // TODO Auto-generated catch block
		    e.printStackTrace();
	    }
	    return queue.get(m++);
	}
	
	

	
	public int getsize()
	{
		return queue.size();
	}
	public LinkedList<P_Event> getQueue() {
		return queue;
	}

}