From ec72a3dadda76705aced9eea2691419c3dda9f1b Mon Sep 17 00:00:00 2001
From: qydysky <qydysky@foxmail.com>
Date: Mon, 4 Jan 2021 00:05:50 +0800
Subject: [PATCH] mq97

---
 msgq/Msgq_test.go | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

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)
 	}
-- 
2.39.2