opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-30 18:10:44 +08:00
Code Issues Packages Projects Releases Wiki Activity

modify variable name whichItemWorst to randomItem to resolve ambiguity (#5436)

Browse Source
This commit is contained in:
jasonjavaYY
2022-11-07 15:22:31 +08:00
committed by GitHub
parent 08bcd80681
commit 0d44ea183e
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
client/src/main/java/org/apache/rocketmq/client/latency/LatencyFaultToleranceImpl.java
+3 -3
View File
@@ -27,7 +27,7 @@ import org.apache.rocketmq.client.common.ThreadLocalIndex;
public class LatencyFaultToleranceImpl implements LatencyFaultTolerance<String> {
private final ConcurrentHashMap<String, FaultItem> faultItemTable = new ConcurrentHashMap<>(16);
private final ThreadLocalIndex whichItemWorst = new ThreadLocalIndex();
private final ThreadLocalIndex randomItem = new ThreadLocalIndex();
@Override
public void updateFaultItem(final String name, final long currentLatency, final long notAvailableDuration) {
@@ -76,7 +76,7 @@ public class LatencyFaultToleranceImpl implements LatencyFaultTolerance<String>
if (half <= 0) {
return tmpList.get(0).getName();
} else {
final int i = this.whichItemWorst.incrementAndGet() % half;
final int i = this.randomItem.incrementAndGet() % half;
return tmpList.get(i).getName();
}
}
@@ -87,7 +87,7 @@ public class LatencyFaultToleranceImpl implements LatencyFaultTolerance<String>
public String toString() {
return "LatencyFaultToleranceImpl{" +
"faultItemTable=" + faultItemTable +
", whichItemWorst=" + whichItemWorst +
", whichItemWorst=" + randomItem +
'}';
}