fix: spawn worker when one die (#10)

If a worker die, it doen"t update gCount so maybeStartG doesn"t start a new one.
neilotoole · Sep 19, 2021 · 2767a51 · 2767a51
1 parent 354d2f8
commit 2767a51
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/errgroup.go b/errgroup.go
@@ -190,6 +190,7 @@ func (g *Group) startG() {
 	g.wg.Add(1)
 	go func() {
 		defer g.wg.Done()
+		defer atomic.AddInt64(&g.gCount, -1)
 
 		var f func() error