diff --git a/workerpool.go b/workerpool.go index 6eb20be..221497d 100644 --- a/workerpool.go +++ b/workerpool.go @@ -143,7 +143,7 @@ func (wp *WorkerPool) Close() error { return nil } wp.closed = true - close(wp.tasks) wp.wg.Wait() + close(wp.tasks) return nil }