From ea52cf9b1668a0d5396ff5ce4e8aa71e5e3800d3 Mon Sep 17 00:00:00 2001
From: Nelson Tavares de Sousa <stu103017@mail.uni-kiel.de>
Date: Mon, 13 Oct 2014 16:39:23 +0200
Subject: [PATCH] Added functionality to stages from old versions
---
.../teetime/examples/experiment01/LegacyCollectorSink.java | 3 ++-
.../teetime/examples/experiment01/LegacyObjectProducer.java | 4 ++++
2 files changed, 6 insertions(+), 1 deletion(-)
diff --git a/src/performancetest/java/teetime/examples/experiment01/LegacyCollectorSink.java b/src/performancetest/java/teetime/examples/experiment01/LegacyCollectorSink.java
index a87507ce..1f24ecf0 100644
--- a/src/performancetest/java/teetime/examples/experiment01/LegacyCollectorSink.java
+++ b/src/performancetest/java/teetime/examples/experiment01/LegacyCollectorSink.java
@@ -46,13 +46,14 @@ public class LegacyCollectorSink<T> {
System.out.println("size: " + this.elements.size());
}
- protected void execute(final T element) {
+ protected Object execute(final T element) {
this.elements.add(element);
if ((this.elements.size() % this.threshold) == 0) {
System.out.println("size: " + this.elements.size());
}
+ return new Object();
// if (this.elements.size() > 90000) {
// // System.out.println("size > 90000: " + this.elements.size());
// }
diff --git a/src/performancetest/java/teetime/examples/experiment01/LegacyObjectProducer.java b/src/performancetest/java/teetime/examples/experiment01/LegacyObjectProducer.java
index 909537a3..4c87ce8f 100644
--- a/src/performancetest/java/teetime/examples/experiment01/LegacyObjectProducer.java
+++ b/src/performancetest/java/teetime/examples/experiment01/LegacyObjectProducer.java
@@ -52,6 +52,10 @@ public class LegacyObjectProducer<T> {
}
protected T execute() {
+ if (this.numInputObjects == 0) {
+ return null;
+ }
+
T newObject = this.inputObjectCreator.create();
this.numInputObjects--;
--
GitLab