1 files changed, 4 insertions, 4 deletions
diff --git a/worker.go b/worker.go
index ec743738..cb788030 100644
--- a/worker.go
+++ b/worker.go
@@ -105,12 +105,12 @@ func (w *Worker) Start() error {
 		w.endState, _ = w.cmd.Process.Wait()
 		if w.waitDone != nil {
 			w.state.set(StateStopped)
-			close(w.waitDone)
 
-			if w.rl != nil {
-				w.mu.Lock()
-				defer w.mu.Unlock()
+			//w.mu.Lock()
+			//defer w.mu.Unlock()
 
+			close(w.waitDone)
+			if w.rl != nil {
 				w.rl.Close()
 			}
 		}