From 692cb5a3bec107491e97a61659aab53d24e71b51 Mon Sep 17 00:00:00 2001 From: xxj <346944475@qq.com> Date: Fri, 18 Dec 2020 19:19:49 +0800 Subject: [PATCH] new --- myqueue/myqueue.go | 5 +++++ myqueue/myqueue_test.go | 1 + 2 files changed, 6 insertions(+) diff --git a/myqueue/myqueue.go b/myqueue/myqueue.go index 2b08854..4ce13eb 100644 --- a/myqueue/myqueue.go +++ b/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 { diff --git a/myqueue/myqueue_test.go b/myqueue/myqueue_test.go index fcaa10a..6dce0eb 100644 --- a/myqueue/myqueue_test.go +++ b/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) + } }()