experiment.java

来自「RFID复杂事件处理系统的研究实验」· Java 代码 · 共 49 行

package test2;

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(waitQueue);
	private static Experiment experiment=new Experiment();
	
	
	private Experiment()
	{
		super();
	}
	
	public void start()
	{
		waitQueue.acceptEvents(P_Event.product());
		//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;
	}

}