From aa9b5e9598fdae9eda7c77696121fec949486127 Mon Sep 17 00:00:00 2001 From: mikespook Date: Fri, 11 Jan 2013 11:33:13 +0800 Subject: [PATCH] Start working loop first --- worker/worker.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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