From 9d76ea923159ff36d462b1809104164e270fce96 Mon Sep 17 00:00:00 2001
From: qinliujie <>
Date: Mon, 9 Jan 2017 11:26:07 +0800
Subject: [PATCH] MASTER [ROCKETMQ-33] Resolve cpu occupy 100% issue in
 GroupCommitService/HAService, closes apache/incubator-rocketmq#31

---
 store/src/main/java/org/apache/rocketmq/store/CommitLog.java    | 2 +-
 store/src/main/java/org/apache/rocketmq/store/ha/HAService.java | 2 +-
 2 files 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 5ebab545..b4bf298b 100644
--- a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
+++ b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
@@ -1045,7 +1045,7 @@ public class CommitLog {
 
             while (!this.isStopped()) {
                 try {
-                    this.waitForRunning(0);
+                    this.waitForRunning(10);
                     this.doCommit();
                 } catch (Exception e) {
                     CommitLog.log.warn(this.getServiceName() + " service has exception. ", e);
diff --git a/store/src/main/java/org/apache/rocketmq/store/ha/HAService.java b/store/src/main/java/org/apache/rocketmq/store/ha/HAService.java
index d2e8cd9f..762bdb6a 100644
--- a/store/src/main/java/org/apache/rocketmq/store/ha/HAService.java
+++ b/store/src/main/java/org/apache/rocketmq/store/ha/HAService.java
@@ -297,7 +297,7 @@ public class HAService {
 
             while (!this.isStopped()) {
                 try {
-                    this.waitForRunning(0);
+                    this.waitForRunning(10);
                     this.doWaitTransfer();
                 } catch (Exception e) {
                     log.warn(this.getServiceName() + " service has exception. ", e);
-- 
GitLab