removed runnables due to performance decrease

src/test/java/teetime/examples/throughput/methodcall/AbstractStage.java

@@ -2,32 +2,8 @@ package teetime.examples.throughput.methodcall;
 
 public abstract class AbstractStage<I, O> implements Stage<I, O> {
 
-	Runnable inputPortIsUsed = new Runnable() {
-		@Override
-		public void run() {
-			// pass through the end signal
-			I element = AbstractStage.this.getInputPort().read();
-			if (element == END_SIGNAL) {
-				AbstractStage.this.getOutputPort().send((O) END_SIGNAL);
-				return;
-			}
-
-			AbstractStage.this.execute3();
-		}
-	};
-
-	Runnable inputPortIsNotUsed = new Runnable() {
-		@Override
-		public void run() {
-			// do not check
-
-			AbstractStage.this.execute3();
-		}
-	};
-
 	private final InputPort<I> inputPort = new InputPort<I>();
 	private final OutputPort<O> outputPort = new OutputPort<O>();
-	protected Runnable endSignalCheck = this.inputPortIsUsed;
 
 	@Override
 	public InputPort<I> getInputPort() {
@@ -41,8 +17,20 @@ public abstract class AbstractStage<I, O> implements Stage<I, O> {
 
 	@Override
 	public final void execute2() {
-		this.endSignalCheck.run();
+		// pass through the end signal
+		InputPort<I> port = this.getInputPort();
+		if (port.pipe != null) {
+			I element = port.read();
+			if (element == END_SIGNAL) {
+				this.getOutputPort().send((O) END_SIGNAL);
+				return;
+			}
+		}
+
+		this.execute3();
 	}
 
 	protected abstract void execute3();
+
+	// protected abstract O[] execute4(I[] elements, int size);
 }

src/test/java/teetime/examples/throughput/methodcall/ObjectProducer.java

@@ -33,8 +33,6 @@ public class ObjectProducer<T> extends AbstractStage<Void, T> {
 	public ObjectProducer(final long numInputObjects, final Callable<T> inputObjectCreator) {
 		this.numInputObjects = numInputObjects;
 		this.inputObjectCreator = inputObjectCreator;
-
-		this.endSignalCheck = this.inputPortIsNotUsed;
 	}
 
 	public T execute() {