nsqd: reduce ReadyCount update frequency

nsqio · Dec 24, 2019 · 368af1a · 368af1a
1 parent f6bc2bf
commit 368af1a
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/nsqd/client_v2.go b/nsqd/client_v2.go
@@ -327,8 +327,11 @@ func (c *clientV2) IsReadyForMessages() bool {
 }
 
 func (c *clientV2) SetReadyCount(count int64) {
-	atomic.StoreInt64(&c.ReadyCount, count)
-	c.tryUpdateReadyState()
+	oldCount := atomic.SwapInt64(&c.ReadyCount, count)
+
+	if oldCount != count {
+		c.tryUpdateReadyState()
+	}
 }
 
 func (c *clientV2) tryUpdateReadyState() {