Skip to content

Commit 1c6c112

Browse files
Maxime WEYLonsi
Maxime WEYL
authored andcommitted
Fix #803
1 parent 4feb9d7 commit 1c6c112

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

gmeasure/experiment.go

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -463,13 +463,19 @@ func (e *Experiment) Sample(callback func(idx int), samplingConfig SamplingConfi
463463
minSamplingInterval := samplingConfig.MinSamplingInterval
464464

465465
work := make(chan int)
466-
defer close(work)
466+
var wg sync.WaitGroup
467+
defer func() {
468+
close(work)
469+
wg.Wait()
470+
}()
467471
if numParallel > 1 {
468472
for worker := 0; worker < numParallel; worker++ {
469473
go func() {
474+
wg.Add(1)
470475
for idx := range work {
471476
callback(idx)
472477
}
478+
wg.Done()
473479
}()
474480
}
475481
}

0 commit comments

Comments
 (0)