Function NewReusableGoroutinesPool

concurrency/worker.go:14–21

NewReusableGoroutinesPool creates a new worker pool with the given size. Workers are created on demand as they're needed up to the specified size. These workers will run the workloads passed through Go() calls. If all workers are busy, Go() will spawn a new goroutine to run the workload.

(size int)

// These workers will run the workloads passed through Go() calls.
// If all workers are busy, Go() will spawn a new goroutine to run the workload.
func NewReusableGoroutinesPool(size int) *ReusableGoroutinesPool {
	p := &ReusableGoroutinesPool{
		jobs:    make(chan func()),
		closed:  make(chan struct{}),
		pending: atomic.NewInt64(int64(size)),
	}
	return p
}

type ReusableGoroutinesPool struct {
	jobs    chan func()