// Start starts worker loops with given parallelism
Start starts worker loops with given parallelism
// Start starts worker loops with given parallelism
func (w *worker) Start() {
	w.startOnce.Do(func() {
		w.workCh = make(chan workRequest, maxWaiting)
		w.done = make(chan struct{})
		w.wg.Add(w.parallelism)
		for i := 0; i < w.parallelism; i++ {
			go w.loop()
		}
	})
}
func ( w * worker ) Start ( ) { w . startOnce . Do ( func ( ) { w . workCh = make ( chan workRequest , maxWaiting ) w . done = make ( chan struct { } ) w . wg . Add ( w . parallelism ) for i := 0 ; i < w . parallelism ; i ++ { go w . loop ( ) } } ) }
Start starts worker loops with given parallelism
Start starts worker loops with given parallelism