From: qydysky <32743305+qydysky@users.noreply.github.com>
Date: Wed, 18 Nov 2020 04:05:43 +0000 (+0800)
Subject: Update Msgq_test.go
X-Git-Tag: v0.3.0~2^2
X-Git-Url: http://127.0.0.1:8081/?a=commitdiff_plain;h=4cfbc537a335dcbac9f2b1f9d5949cf369759e9d;p=part%2F.git

Update Msgq_test.go
---

diff --git a/msgq/Msgq_test.go b/msgq/Msgq_test.go
index 83868b7..3740ac5 100644
--- a/msgq/Msgq_test.go
+++ b/msgq/Msgq_test.go
@@ -7,14 +7,22 @@ import (
 
 func Test_msgq(t *testing.T) {
 	mq := New()
-	go func(){
-		for mq.Pull().(string) == `mmm` {;}
-		t.Error(`0`)
-	}()	
-	go func(){
-		for mq.Pull().(string) == `mmm` {;}
-		t.Error(`0`)
-	}()
-	p.Sys().Timeoutf(1)
+	k := 0
+	var e bool
+	for i:=0;i<1e5;i++{
+		go func(){
+			k += 1
+			if o,ok:=mq.Pull().(string);o != `mmm`||!ok {e = true}
+			k += 1
+		}()
+	}
+	p.Sys().Timeoutf(2)
+	t.Log(`>`,k)
+	k = 0
+
 	mq.Push(`mmm`)
+
+	p.Sys().Timeoutf(1)
+	t.Log(`<`,k)
+	if e {t.Error("f")}
 }