diff --git a/msgqueue.go b/msgqueue.go index 684cc59..0cc0dde 100644 --- a/msgqueue.go +++ b/msgqueue.go @@ -15,6 +15,8 @@ type msgQueue struct { msgHandlers [256] struct { lock sync.Mutex head q5.ListHead + delingLock sync.Mutex + delingHandlers []*MsgHandler addingLock sync.Mutex addingHead q5.ListHead }