From 3496ee3128b9bb720cd525b1b94abdc7afee7163 Mon Sep 17 00:00:00 2001
From: Christian Wulf <chw@informatik.uni-kiel.de>
Date: Wed, 20 May 2015 08:19:44 +0200
Subject: [PATCH] minor refactoring
---
.../distributor/RoundRobinStrategy2.java | 19 +++++++++++--------
1 file changed, 11 insertions(+), 8 deletions(-)
diff --git a/src/main/java/teetime/stage/basic/distributor/RoundRobinStrategy2.java b/src/main/java/teetime/stage/basic/distributor/RoundRobinStrategy2.java
index e62f221b..829e9f7e 100644
--- a/src/main/java/teetime/stage/basic/distributor/RoundRobinStrategy2.java
+++ b/src/main/java/teetime/stage/basic/distributor/RoundRobinStrategy2.java
@@ -38,14 +38,7 @@ public final class RoundRobinStrategy2 implements IDistributorStrategy {
success = outputPort.sendNonBlocking(element);
if (0 == numLoops) {
numWaits++;
- // Thread.yield();
- try {
- Thread.sleep(1);
- } catch (InterruptedException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
-
+ backoff();
numLoops = numOutputPorts;
}
numLoops--;
@@ -54,6 +47,16 @@ public final class RoundRobinStrategy2 implements IDistributorStrategy {
return true;
}
+ private void backoff() {
+ try {
+ Thread.sleep(1);
+ } catch (InterruptedException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
+ // Thread.yield();
+ }
+
private <T> OutputPort<T> getNextPortInRoundRobinOrder(final OutputPort<T>[] outputPorts) {
final OutputPort<T> outputPort = outputPorts[this.index];
--
GitLab