From b8ccbdd770c8469db98340d456f232a9536de95b Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Sat, 16 Nov 2024 15:05:51 +0800 Subject: [PATCH] 1 --- server/wheelserver/service/log.go | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/server/wheelserver/service/log.go b/server/wheelserver/service/log.go index d2f0a5c8..57f1e9a2 100644 --- a/server/wheelserver/service/log.go +++ b/server/wheelserver/service/log.go @@ -30,9 +30,12 @@ func (this *log) unInit() { func (this *log) saveToDb() { for true { - this.loopCond.L.Lock() - this.loopCond.Wait() - this.loopCond.L.Unlock() + this.logQueue.Fetch() + if this.logQueue.IsEmpty() { + this.loopCond.L.Lock() + this.loopCond.Wait() + this.loopCond.L.Unlock() + } } }