Method Go

concurrency/worker.go:31–44

Go will run the given function in a worker of the pool. If all workers are busy, Go() will spawn a new goroutine to run the workload.

(f func())

// Go will run the given function in a worker of the pool.
// If all workers are busy, Go() will spawn a new goroutine to run the workload.
func (p *ReusableGoroutinesPool) Go(f func()) {
	select {
	case p.jobs <- f:
	default:
		if pending := p.pending.Dec(); pending >= 0 {
			p.newWorker(f)
			return
		} else if pending < math.MinInt64/2 {
			// Wow, that's a lot of goroutines created, make sure we don't overflow.
			p.pending.Store(0)
		}
		go f()
	}
}

func (p *ReusableGoroutinesPool) newWorker(f func()) {
	go func() {