new

myqueue/myqueue.go

@@ -151,6 +151,11 @@ func (q *MyQueue) Close() {
 	}
 }
 
+// IsClose check is closed
+func (q *MyQueue) IsClose() bool {
+	return q.closed
+}
+
 //Wait 等待队列消费完成
 func (q *MyQueue) Wait() {
 	for {

myqueue/myqueue_test.go

@@ -110,6 +110,7 @@ func TestTimeout(t *testing.T) {
 		for i := 0; i < 10; i++ { //开启20个请求
 			time.Sleep(1 * time.Second)
 			que.Push(i)
+
 		}
 	}()