diff options
| -rw-r--r-- | skate/zipkey/batch.go | 2 |
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 |