From 84357fb0aba24ad3392ffe3be0a4492bb82fc645 Mon Sep 17 00:00:00 2001
From: Christian Wulf <chw@informatik.uni-kiel.de>
Date: Thu, 19 Mar 2015 14:17:32 +0100
Subject: [PATCH] optimized RoundRobinStrategy2
---
.../stage/basic/distributor/RoundRobinStrategy2.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git a/src/main/java/teetime/stage/basic/distributor/RoundRobinStrategy2.java b/src/main/java/teetime/stage/basic/distributor/RoundRobinStrategy2.java
index 402daddc..e46807aa 100644
--- a/src/main/java/teetime/stage/basic/distributor/RoundRobinStrategy2.java
+++ b/src/main/java/teetime/stage/basic/distributor/RoundRobinStrategy2.java
@@ -29,11 +29,12 @@ public final class RoundRobinStrategy2 implements IDistributorStrategy {
@Override
public <T> boolean distribute(final OutputPort<T>[] outputPorts, final T element) {
- int numLoops = outputPorts.length;
+ final int numOutputPorts = outputPorts.length;
+ int numLoops = numOutputPorts;
boolean success;
do {
- OutputPort<T> outputPort = getNextPortInRoundRobinOrder(outputPorts);
+ final OutputPort<T> outputPort = getNextPortInRoundRobinOrder(outputPorts);
success = outputPort.sendNonBlocking(element);
numLoops--;
if (0 == numLoops) {
@@ -46,7 +47,7 @@ public final class RoundRobinStrategy2 implements IDistributorStrategy {
e.printStackTrace();
}
- numLoops = outputPorts.length;
+ numLoops = numOutputPorts;
}
} while (!success);
--
GitLab