Struct BoundedWaitGroup

pkg/boundedwaitgroup/boundedwaitgroup.go:6–9

BoundedWaitGroup like a normal wait group except limits number of active goroutines to given capacity.

// BoundedWaitGroup like a normal wait group except limits number of active goroutines to given capacity.
type BoundedWaitGroup struct {
	wg sync.WaitGroup
	ch chan struct{} // Chan buffer size is used to limit concurrency.
}

// New creates a BoundedWaitGroup with the given concurrency.
func New(capacity uint) BoundedWaitGroup {