Function New

workerpool.go:32–57

New makes a new *WorkerPool.

(workerCount, jobQueueSize int)

// New makes a new *WorkerPool.
func New(workerCount, jobQueueSize int) *WorkerPool {
	if jobQueueSize < 0 {
		jobQueueSize = 0
	}
	if workerCount < 0 {
		workerCount = runtime.NumCPU()
	}
	pool := WorkerPool{
		pool: make(chan chan func(), workerCount),
		jobs: make(chan func(), jobQueueSize),
		quit: make(chan struct{}),
		wg:   sync.WaitGroup{},
	}
	for i := 0; i < workerCount; i++ {
		var builder workerBuilder
		w := builder.
			withPool(pool.pool).
			withPoolQuit(pool.quit).
			withTimeout(0).
			withQuit(pool.quit).
			build()
		w.initWorker(&pool.wg)
	}
	go pool.dispatch()
	return &pool
}

// Queue queues a job to be run by a worker.
func (pool *WorkerPool) Queue(job func(), timeout time.Duration) bool {