Method Start

job/queue.go:57–70

Start consuming task

()

//Start consuming task
func (worker *Worker) Start() {
	go func() {
		l.Panic(log)
		for {
			select {
			case job := <-worker.queue.queue:
				job.Run()
				worker.queue.waitGroup.Done()
			case <-worker.CloseCh:
				return
			}
		}
	}()
}

//Queue manages workers and job
type Queue struct {