serversimulation.java

高质量Java程序设计 源代码

package net.betterjava.sample.xml.bind.test;

import java.io.FileNotFoundException;

import net.betterjava.sample.xml.bind.WrongFormatException;
import net.betterjava.sample.xml.bind.XMLTransformer;
import net.betterjava.sample.xml.bind.XMLTransformerFactory;

public class ServerSimulation extends Thread {
	private Semaphore semaphore = null;
	private XMLTransformer transformer;

	public ServerSimulation(Semaphore smp, String schemaPath)
		throws FileNotFoundException {
		super();
		semaphore = smp;
		XMLTransformerFactory transformerFactory = XMLTransformerFactory.newInstance();
		transformerFactory.setSchemaPath(schemaPath);
		transformer = transformerFactory.newXMLTransformer();
	}

	public void run() {
		semaphore.waitAllReady();
		while (semaphore.hasNext()) {
			String data = semaphore.nextInput();
			try {
				long time = System.currentTimeMillis();
				transformer.transform(data);
				time = System.currentTimeMillis() - time;
				semaphore.elapse(time);
			} catch (WrongFormatException e1) {
				e1.printStackTrace(System.out);
			}
		}
		System.out.println(
			Thread.currentThread() + " stop at " + System.currentTimeMillis());
	}
}