aboutsummaryrefslogtreecommitdiffstats
path: root/skate/zipkey/batch.go
diff options
context:
space:
mode:
Diffstat (limited to 'skate/zipkey/batch.go')
-rw-r--r--skate/zipkey/batch.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/skate/zipkey/batch.go b/skate/zipkey/batch.go
index e8ba052..031a1fc 100644
--- a/skate/zipkey/batch.go
+++ b/skate/zipkey/batch.go
@@ -38,8 +38,8 @@ func NewBatcherSize(gf groupFunc, size int) *Batcher {
NumWorkers: runtime.NumCPU(),
queue: make(chan []*Group),
}
+ batcher.wg.Add(batcher.NumWorkers)
for i := 0; i < batcher.NumWorkers; i++ {
- batcher.wg.Add(1)
go batcher.worker()
}
return &batcher