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-11-06 15:22:32 +08:00
parent 6ef94d7442
commit 37a99c4226
1 changed files with 17 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
msgqueue.go
View File

@ -72,10 +72,13 @@ func (this *msgQueue) FireEvent(msgId int, args q5.Args) {
if !h.deleted { if !h.deleted {
h.cb(args) h.cb(args)
} else { } else {
h.entry.DelInit() node.delingLock.Lock()
q5.AppendSlice(&node.delingHandlers, h)
node.delingLock.Unlock()
} }
return true return true
}) })
this.clearNode(&node.delingLock, &node.delingHandlers)
node.addingLock.Lock() node.addingLock.Lock()
defer node.addingLock.Unlock() defer node.addingLock.Unlock()
if !node.addingHead.Empty() { if !node.addingHead.Empty() {
@ -86,8 +89,21 @@ func (this *msgQueue) FireEvent(msgId int, args q5.Args) {
if !h.deleted { if !h.deleted {
node.head.AddTail(&h.entry) node.head.AddTail(&h.entry)
h.cb(args) h.cb(args)
} else {
node.delingLock.Lock()
q5.AppendSlice(&node.delingHandlers, h)
node.delingLock.Unlock()
} }
return true return true
}) })
} }
this.clearNode(&node.delingLock, &node.delingHandlers)
}
func (this *msgQueue) clearNode(delingLock *sync.Mutex, delingHandlers *[]*MsgHandler) {
delingLock.Lock()
defer delingLock.Unlock()
if len(*delingHandlers) > 0 {
*delingHandlers = []*MsgHandler{}
}
} }