optimize worker queue

2018-05-19 12:36:28 +08:00 · 2018-05-19 12:36:28 +08:00 · 7bf85c2a66
parent e683ddc821
commit 7bf85c2a66
1 changed files with 1 additions and 0 deletions
--- a/worker.go
+++ b/worker.go
@ -14,6 +14,7 @@ func (w *Worker) run() {
 			select {
 			case f := <-w.task:
 				f()
+				w.pool.workers <- w
 			case <-w.exit:
 				atomic.AddInt32(&w.pool.length, -1)
 				return