Method Queue

workerpool.go:60–76

Queue queues a job to be run by a worker.

(job func(), timeout time.Duration)

// Queue queues a job to be run by a worker.
func (pool *WorkerPool) Queue(job func(), timeout time.Duration) bool {
	if pool.stopped() {
		return false
	}
	var t <-chan time.Time
	if timeout > 0 {
		t = time.After(timeout)
	}
	select {
	case pool.jobs <- job:
	case <-t:
		return false
	case <-pool.quit:
		return false
	}
	return true
}

// Stop stops the pool and waits for all workers to return.
func (pool *WorkerPool) Stop() {