Commit 4a2b41f1 authored by Tim Leers's avatar Tim Leers

Change order of adding worker to waitgroup

parent 2506b53d
...@@ -362,8 +362,8 @@ func (qs *NamespaceQueues) next() { ...@@ -362,8 +362,8 @@ func (qs *NamespaceQueues) next() {
wg: qs.wg, wg: qs.wg,
} }
qs.workers[ns] = worker qs.workers[ns] = worker
go worker.work()
qs.wg.Add(1) qs.wg.Add(1)
go worker.work()
} }
worker.queue.Add(obj) worker.queue.Add(obj)
qs.Queue.Forget(obj) qs.Queue.Forget(obj)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment