opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-01 15:47:01 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #2785 from Kingdon1992/fix_bug_in_ThreadLocalIndex

Browse Source 
[ISSUE #2783]Fix bug in ThreadLocalIndex
This commit is contained in:
Heng Du
2021-05-23 21:39:04 +08:00
committed by GitHub
parent 59718fd905 b78326d869
commit 2fb5f7acac
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
client/src/main/java/org/apache/rocketmq/client/common/ThreadLocalIndex.java
+2 -3
View File
@@ -30,9 +30,8 @@ public class ThreadLocalIndex {
this.threadLocalIndex.set(index);
}
index = Math.abs(index + 1);
this.threadLocalIndex.set(index);
return index;
this.threadLocalIndex.set(++index);
return Math.abs(index);
}
@Override