Fix Issue #3

letsfire · Nov 18, 2019 · e76a76f · e76a76f
1 parent 5b15285
commit e76a76f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/worker.go b/worker.go
@@ -57,14 +57,14 @@ func newWorker() (w *worker) {
 		}
 		// 置为繁忙状态
 		atomic.StoreInt32(&w.isBusy, 1)
+		// 关闭任务通道
+		defer close(w.params)
 		// 可能存在任务
 		select {
 		case params := <-w.params:
 			w.action(params)
 		case <-time.Tick(time.Millisecond):
 		}
-		// 关闭任务通道
-		close(w.params)
 	}(w)
 	return
 }