experiment.java

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

package test1;

import java.util.Observable;

public class Experiment extends Observable {
	private WaitQueue waitQueue=new WaitQueue();
	private Detection detection=new Detection(waitQueue);
	private EventStream eventStream=new EventStream(detection.getWaitQueue());
	private static Experiment experiment=new Experiment();
	
	
	private Experiment()
	{
		super();
	}
	
	public void start()
	{
		 Thread athread=new Thread(eventStream);
	     Thread bthread=new Thread(detection);
	        
	     athread.start();
	     bthread.start();
		//eventStream.produce();
		//detection.run();
	        
	        
	}

	public Detection getDetection() {
		return detection;
	}

	public EventStream getEventStream() {
		return eventStream;
	}

	public WaitQueue getWaitQueue() {
		return waitQueue;
	}

	public static Experiment getExperiment() {
		return experiment;
	}

}