Fix: defaultTaskQNumber -> p.tQNumber

3c7f2913 · AlexStocks · 1e0ac263 · 3c7f2913
Commit 3c7f2913 authored Jun 09, 2019 by AlexStocks
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 1 deletion

task_pool.go task_pool.go +1 -1

No files found.
--- a/task_pool.go
+++ b/task_pool.go
@@ -85,7 +85,7 @@ func (p *TaskPool) run(id int, q chan task) {

 // add task
 func (p *TaskPool) AddTask(t task) {
-	id := atomic.AddUint32(&p.idx, 1) % defaultTaskQNumber
+	id := atomic.AddUint32(&p.idx, 1) % uint32(p.tQNumber)

 	select {
 	case <-p.done: