diff --git a/workerpool.go b/workerpool.go index d640cb1..71d262a 100644 --- a/workerpool.go +++ b/workerpool.go @@ -94,9 +94,8 @@ func (wp *WorkerPool) Submit(id string, f func(ctx context.Context) error) error wp.mu.Unlock() return ErrDraining } - - wp.mu.Unlock() wp.wg.Add(1) + wp.mu.Unlock() wp.tasks <- &task{ id: id, run: f,