removed comments

src/main/java/teetime/framework/concurrent/WorkerThread.java

@@ -73,7 +73,7 @@ public class WorkerThread extends Thread {
 			// beforeStageExecutionStopWatch.end();
 
 			this.startStageExecution(stage);
-			// stageExecutionStopWatch.start(); // expensive: takes 1/3 of overall time
+			// stageExecutionStopWatch.start();
 			final boolean executedSuccessfully = stage.execute();
 			// stageExecutionStopWatch.end();
 			this.finishStageExecution(stage, executedSuccessfully);

src/main/java/teetime/framework/core/AbstractFilter.java

@@ -178,7 +178,7 @@ public abstract class AbstractFilter<S extends IStage> extends AbstractStage imp
 	@Override
 	public void onPortIsClosed(final IInputPort<S, ?> inputPort) {
 		// inputPort.setState(IInputPort.State.CLOSING);
-		this.enabledInputPorts--;
+		this.enabledInputPorts--;	// FIXME not thread-safe
 		// this.logger.info("Closed " + "(" + this.enabledInputPorts + " remaining) " + inputPort + " of " + this);
 
 		if (this.enabledInputPorts < 0) {