diff options
Diffstat (limited to 'modules/queue/workerpool.go')
| -rw-r--r-- | modules/queue/workerpool.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/modules/queue/workerpool.go b/modules/queue/workerpool.go index 63ec897481..952e87681e 100644 --- a/modules/queue/workerpool.go +++ b/modules/queue/workerpool.go @@ -132,8 +132,8 @@ func (p *WorkerPool) pushBoost(data Data) { p.blockTimeout /= 2 p.lock.Unlock() }() - p.addWorkers(ctx, boost) p.lock.Unlock() + p.addWorkers(ctx, boost) p.dataChan <- data } } |