Function New

pkg/boundedwaitgroup/boundedwaitgroup.go:12–17

New creates a BoundedWaitGroup with the given concurrency.

(capacity uint)

// New creates a BoundedWaitGroup with the given concurrency.
func New(capacity uint) BoundedWaitGroup {
	if capacity == 0 {
		panic("BoundedWaitGroup capacity must be greater than zero or else it will block forever.")
	}
	return BoundedWaitGroup{ch: make(chan struct{}, capacity)}
}

// Add the number of items to the group. Blocks until there is capacity.
func (bwg *BoundedWaitGroup) Add(delta int) {