threadcontainer.java

本人历尽千辛万苦找的clustream中的jar包

package  org.osu.ogsa.stream.services;

//This class is created for running the application 
//in a thread
class ThreadContainer extends Thread
{
	private StreamServiceProvider ssp;
	private StreamProcessor processor;

	public ThreadContainer(StreamServiceProvider ssp)
	{
		this.ssp = ssp;
	}

	public void run()
	{
		//get inBufArray and outBufArray
		ssp.startJob();
		processor.work(ssp.inBufArray, ssp.outBufArray);
		ssp.finishJob();
	}
	public void initProcessing(StreamProcessor proc)
	{
		this.processor = proc;
		processor.init(ssp);
	}

	public void startProcessing()
	{
		start();
	}
}