mq97

diff --git a/msgq/Msgq_test.go b/msgq/Msgq_test.go
index 867473c81eeddba211b52ab161a9e1788379688b..cd9ab784348da5b98f9a90f80c42115305244b13 100644 (file)
--- a/msgq/Msgq_test.go
+++ b/msgq/Msgq_test.go
@@ -109,11 +109,10 @@ func Test_msgq2(t *testing.T) {
 func Test_msgq3(t *testing.T) {
        mq := New(100)
 
-       mun_c := make(chan bool,100)
+       mun_c := make(chan int,100)
        mq.Pull_tag(map[string]func(interface{})(bool){
                `A1`:func(data interface{})(bool){
-                       if v,ok := data.(string);!ok || v != `a11`{t.Error(`1`)}
-                       mun_c <- true
+                       if v,ok := data.(int);ok {mun_c <- v}
                        return false
                },
        })
@@ -122,8 +121,8 @@ func Test_msgq3(t *testing.T) {
        t.Log(`start`)
        time.Sleep(time.Second)
        for fin_turn < 10000000 {
-               mq.Push_tag(`A1`,`a11`)
-               <-mun_c
+               mq.Push_tag(`A1`,fin_turn)
+               if fin_turn != <-mun_c {t.Error(fin_turn)}
                fin_turn += 1
                fmt.Print("\r",fin_turn)
        }