Fix race of WaitGroup Done before Add

unicell · May 20, 2016 · cfabeaa · cfabeaa
1 parent 634428f
commit cfabeaa
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/jobpool.go b/jobpool.go
@@ -15,8 +15,8 @@ func addJob(job Job, pending chan<- Job) {
 	glog.V(2).Infof("--> data - submitting chunk...")
 	glog.V(4).Infof("\n>\n%s<\n", string(job.GetData()))
 
-	pending <- job
 	inWg.Add(1)
+	pending <- job
 }
 
 func initJobPool(args []string, r io.Reader, pending chan Job) {

diff --git a/worker.go b/worker.go
@@ -28,8 +28,8 @@ func Worker(in <-chan Job, out chan<- Job) {
 			glog.Errorf("Error executing %v", err)
 			continue
 		}
-		out <- j
 		outWg.Add(1)
+		out <- j
 	}
 }