diff options
| -rw-r--r-- | classic.go | 7 |
1 files changed, 4 insertions, 3 deletions
@@ -40,12 +40,13 @@ loop: numPendingSends++ wg.Go(func() { + sema <- struct{}{} + defer func() { <-sema }() + select { case <-ctx.Done(): return - case sema <- struct{}{}: - defer func() { <-sema }() - worklist <- getBatch(u) + case worklist <- getBatch(u): } }) } |
