92

diff --git a/msgq/Msgq.go b/msgq/Msgq.go
index 0f0761bfb438d201d9241f5049e4ac8f5937b41c..d0fdc2e5066de751837f59b3bec0c85ed0572ca2 100644 (file)
--- a/msgq/Msgq.go
+++ b/msgq/Msgq.go
@@ -7,15 +7,19 @@ type msgq struct {
 
 func New() (*msgq) {
        l := new(msgq)
-       (*l).o = make(chan interface{})
-       (*l).men = make(chan bool)
+       (*l).o = make(chan interface{},1e9)
+       (*l).men = make(chan bool,1e9)
        return l
 }
 
 func (m *msgq) Push(msg interface{}) {
-       if len(m.men) == 0  {return}
-       for <- m.men {
+       num := len(m.men)
+       for len(m.men) != 0 {
+               <- m.men
+       }
+       for num > 0 {
                m.o <- msg
+               num -= 1
        }
        for len(m.o) != 0 {
                <- m.o