lock for stop

1 files changed, 1 insertions, 1 deletions

diff --git a/worker.go b/worker.go
index 8fbaa892..d581481f 100644
--- a/worker.go
+++ b/worker.go
@@ -126,7 +126,7 @@ func (w *Worker) Start() error {
 func (w *Worker) Wait() error {
 	<-w.waitDone
 
-	// ensure that all pipe descriptors are closed
+	// ensure that all read/write operations are complete
 	w.mu.Lock()
 	defer w.mu.Unlock()