From: qydysky <qydysky@foxmail.com>
Date: Sun, 3 Jan 2021 16:05:50 +0000 (+0800)
Subject: mq97
X-Git-Tag: v0.3.6~6
X-Git-Url: http://127.0.0.1:8081/?a=commitdiff_plain;h=ec72a3dadda76705aced9eea2691419c3dda9f1b;p=part%2F.git

mq97
---

diff --git a/msgq/Msgq_test.go b/msgq/Msgq_test.go
index 867473c..cd9ab78 100644
--- 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)
 	}