()
| 43 | } |
| 44 | |
| 45 | func (w *boundedWaitGroup) Done() { |
| 46 | select { |
| 47 | case _, ok := <-w.sem: |
| 48 | if !ok { |
| 49 | logs.Err.Panicln("boundedWaitGroup.sem closed.") |
| 50 | } |
| 51 | default: |
| 52 | logs.Err.Panicln("boundedWaitGroup.Done() called before Add().") |
| 53 | } |
| 54 | w.wg.Done() |
| 55 | } |
| 56 | |
| 57 | func (w *boundedWaitGroup) Wait() { |
| 58 | w.wg.Wait() |
no outgoing calls