bingyi/gf
1
0
Fork 0
mirror of https://gitee.com/johng/gf synced 2026-07-03 03:39:35 +08:00
Code Issues Packages Projects Releases Wiki Activity

gcache改进

Browse Source
This commit is contained in:
John
2018-09-18 00:01:10 +08:00
parent 447f8f7f3a
commit 73a6293845
7 changed files with 194 additions and 149 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
g/container/gqueue/gqueue.go
View File

@ -61,8 +61,12 @@ func (q *Queue) startAsyncLoop() {
case <- q.closeChan:
return
case <- q.events:
if v := q.list.PopFront(); v != nil {
q.queue <- v
for {
if v := q.list.PopFront(); v != nil {
q.queue <- v
} else {
break
}
}
}
}
@ -74,9 +78,7 @@ func (q *Queue) Push(v interface{}) {
q.queue <- v
} else {
q.list.PushBack(v)
if len(q.events) == 0 {
q.events <- struct{}{}
}
q.events <- struct{}{}
}
}