diff --git a/worker/worker.go b/worker/worker.go index 4d5fa7b..76a391d 100644 --- a/worker/worker.go +++ b/worker/worker.go @@ -279,6 +279,7 @@ func (worker *Worker) exec(inpack *inPack) (err error) { } outpack.handle = inpack.handle outpack.data = r.data + //exec() maybe called concurrently, take care of race condition inpack.a.write(outpack) } return