Fix: start task pool

00a82ce8 · AlexStocks · 4fbff185 · 00a82ce8
Commit 00a82ce8 authored Jun 24, 2019 by AlexStocks
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 0 deletions

task_pool.go task_pool.go +1 -0

No files found.
--- a/task_pool.go
+++ b/task_pool.go
@@ -46,6 +46,7 @@ func NewTaskPool(opts ...TaskPoolOption) *TaskPool {
 	for i := 0; i < p.tQNumber; i++ {
 		p.qArray[i] = make(chan task, p.tQLen)
 	}
+	p.start()

 	return p
 }