server_common/f5
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
aozhiwei 2024-06-29 21:03:54 +08:00
parent 71fae94866
commit 2ff2d1c71b
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
dbpool.go
View File

@ -143,10 +143,10 @@ func (this *dbPool) LoopLoad(
nextTimeCb func() int64, nextTimeCb func() int64,
nextRoundCb func() int64, nextRoundCb func() int64,
doCb func(*DataSet) bool) { doCb func(*DataSet) bool) {
newDataCond := sync.NewCond(new(sync.Mutex)) cond := sync.NewCond(new(sync.Mutex))
chTimer := make(chan int64) chTimer := make(chan int64)
go this.discoverNewData(dataSource, watchTable, watchTimeCb, newDataCond) go this.discoverNewData(dataSource, watchTable, watchTimeCb, cond)
go q5.CreateCondTimer(chTimer, newDataCond) go q5.CreateCondTimer(chTimer, cond, 10)
var lastIdx int64 var lastIdx int64
for true { for true {
@ -177,9 +177,9 @@ func (this *dbPool) LoopLoad(
lastIdx = 0 lastIdx = 0
chTimer <- nextRoundCb() chTimer <- nextRoundCb()
} }
newDataCond.L.Lock() cond.L.Lock()
newDataCond.Wait() cond.Wait()
newDataCond.L.Unlock() cond.L.Unlock()
} }
} }