move line WaitGroup.Done

hichtakk · Apr 28, 2016 · 1feae06 · 1feae06
1 parent bad4163
commit 1feae06
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/tarpan.go b/tarpan.go
@@ -259,6 +259,7 @@ func Collect(dataset *DataSet) []*TarpanResult {
 
 		waitGroup.Add(1)
 		go func(ds *DataSet, idx int, o []string, c *Channels) {
+			defer waitGroup.Done()
 			c.semaphoe <- 0
 			req_body, req_body_err := makeRequestBody(ds, idx)
 			if req_body_err != nil {
@@ -281,7 +282,6 @@ func Collect(dataset *DataSet) []*TarpanResult {
 			}
 			c.results <- ret
 			<-c.semaphoe
-			waitGroup.Done()
 		}(dataset, index, oids, channels)
 	}
 	waitGroup.Wait()