Method begin

workerpool.go:149–173

(wg *sync.WaitGroup)

}

func (w *worker) begin(wg *sync.WaitGroup) {
	wg.Add(1)
	go func() {
		defer wg.Done()
		var timeout <-chan time.Time

		for {
			if w.shouldQuit(timeout) {
				return
			}

			if w.timeout > 0 {
				timeout = time.After(w.timeout)
			}

			if !w.registerInPool(timeout) {
				return
			}

			if !w.executeJob() {
				return
			}
		}
	}()
}

func (w *worker) shouldQuit(timeout <-chan time.Time) (ok bool) {
	select {