This is an automated email from the ASF dual-hosted git repository.

oliverwqcwrw pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new bcf40a911 [ISSUE #6516] Remove redundant code from ThreadLocalIndex 
(#6517)
bcf40a911 is described below

commit bcf40a91190d00b495db1dc625df5050f03fdbcb
Author: xuziyang <[email protected]>
AuthorDate: Mon May 8 17:03:16 2023 +0800

    [ISSUE #6516] Remove redundant code from ThreadLocalIndex (#6517)
---
 .../main/java/org/apache/rocketmq/client/common/ThreadLocalIndex.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/client/src/main/java/org/apache/rocketmq/client/common/ThreadLocalIndex.java 
b/client/src/main/java/org/apache/rocketmq/client/common/ThreadLocalIndex.java
index 5fd41c817..4a3d90135 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/common/ThreadLocalIndex.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/common/ThreadLocalIndex.java
@@ -30,7 +30,7 @@ public class ThreadLocalIndex {
             index = random.nextInt();
         }
         this.threadLocalIndex.set(++index);
-        return Math.abs(index & POSITIVE_MASK);
+        return index & POSITIVE_MASK;
     }
 
     @Override

Reply via email to