This is an automated email from the ASF dual-hosted git repository.
lizhimin 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 275cc65dd7 [ISSUE #9491] Remove the volatile declaration for the two
variables requestsWrite and requestsRead in the GroupCommitService class (#9492)
275cc65dd7 is described below
commit 275cc65dd7ee8ddbed7b2ded0249315cc2558c9b
Author: huanzhikang <[email protected]>
AuthorDate: Sat Jun 28 14:30:54 2025 +0800
[ISSUE #9491] Remove the volatile declaration for the two variables
requestsWrite and requestsRead in the GroupCommitService class (#9492)
---
store/src/main/java/org/apache/rocketmq/store/CommitLog.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
index a64b538042..2fdd2450e6 100644
--- a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
+++ b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
@@ -1610,8 +1610,8 @@ public class CommitLog implements Swappable {
* GroupCommit Service
*/
class GroupCommitService extends FlushCommitLogService {
- private volatile LinkedList<GroupCommitRequest> requestsWrite = new
LinkedList<>();
- private volatile LinkedList<GroupCommitRequest> requestsRead = new
LinkedList<>();
+ private LinkedList<GroupCommitRequest> requestsWrite = new
LinkedList<>();
+ private LinkedList<GroupCommitRequest> requestsRead = new
LinkedList<>();
private final PutMessageSpinLock lock = new PutMessageSpinLock();
public void putRequest(final GroupCommitRequest request) {
