优化RankService

2026-02-07 17:24:41 +08:00 · 2024-05-07 19:11:42 +08:00
1 changed files with 1 additions and 1 deletions
--- a/sysservice/rankservice/MongodbPersist.go
+++ b/sysservice/rankservice/MongodbPersist.go
@@ -263,7 +263,7 @@ func (mp *MongoPersist) JugeTimeoutSave() bool{

 func (mp *MongoPersist)  persistCoroutine(){
 	defer mp.waitGroup.Done()
-	for atomic.LoadInt32(&mp.stop)==0 || mp.hasPersistData(){
+	for atomic.LoadInt32(&mp.stop)==0 {
 		//间隔时间sleep
 		time.Sleep(time.Second*1)