From f4caa13b2879c192da045ea9385a0f050248835d Mon Sep 17 00:00:00 2001
From: chenpengdev <chenpeng@ghostcloud.cn>
Date: Mon, 19 Mar 2018 19:46:54 +0800
Subject: [PATCH] fix go test TestSkipEnqueue error, move queue.Run (#2209)

---
 internal/task/queue_test.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/internal/task/queue_test.go b/internal/task/queue_test.go
index cbfd9a49b..6cc1f3508 100644
--- a/internal/task/queue_test.go
+++ b/internal/task/queue_test.go
@@ -137,8 +137,6 @@ func TestSkipEnqueue(t *testing.T) {
 	atomic.StoreUint32(&sr, 0)
 	q := NewCustomTaskQueue(mockSynFn, mockKeyFn)
 	stopCh := make(chan struct{})
-	// run queue
-	go q.Run(time.Second, stopCh)
 	// mock object whichi will be enqueue
 	mo := mockEnqueueObj{
 		k: "testKey",
@@ -148,6 +146,8 @@ func TestSkipEnqueue(t *testing.T) {
 	q.Enqueue(mo)
 	q.Enqueue(mo)
 	q.Enqueue(mo)
+	// run queue
+	go q.Run(time.Second, stopCh)
 	// wait for 'mockSynFn'
 	time.Sleep(time.Millisecond * 10)
 	if atomic.LoadUint32(&sr) != 1 {