From: qydysky Date: Wed, 18 Nov 2020 20:11:47 +0000 (+0800) Subject: 92 X-Git-Tag: v0.3.0~1 X-Git-Url: http://127.0.0.1:8081/?a=commitdiff_plain;h=5c672b694ad462348bea07fd5b724669362be1d2;p=part%2F.git 92 --- diff --git a/msgq/Msgq.go b/msgq/Msgq.go index 169efe8..c5fabf1 100644 --- a/msgq/Msgq.go +++ b/msgq/Msgq.go @@ -15,6 +15,7 @@ func New() (*msgq) { } func (m *msgq) Push(msg interface{}) { + <- m.i m.i = make(chan struct{}) m.d = msg close(m.o)