diff --git a/worker/worker.go b/worker/worker.go index ad9a7fb..33f6140 100644 --- a/worker/worker.go +++ b/worker/worker.go @@ -190,13 +190,13 @@ func (worker *Worker) Work() { v.Close() } }() - for funcname, f := range worker.funcs { - worker.addFunc(funcname, f.timeout) - } worker.running = true for _, v := range worker.agents { go v.Work() } + for funcname, f := range worker.funcs { + worker.addFunc(funcname, f.timeout) + } ok := true for ok { var job *Job