package scheduler

import (
	"gitee.com/h79/goutils/common/system"
)

type jobWorker struct {
	pool    *Pool
	job     chan *Job
	running system.RunningCheck
	stop    chan bool
}

func (w *jobWorker) start() {
	w.running.GoRunning(w.run)
}

func (w *jobWorker) run() {
	w.pool.workerRunning()
	defer w.pool.workerQuit()
	for {
		w.pool.workers <- w //把idle work放进去
		select {
		case job := <-w.job:
			ctrl := system.NewCtrl()
			//超时
			res, err := ctrl.RunAfter(job.Timeout, func() (interface{}, error) {
				return job.Execute()
			})
			job.done(&Result{Type: job.Type, Id: job.Id, Data: res, Err: err})

			w.pool.workerIdle()

		case <-w.stop:
			w.stop <- true
			return
		}
	}
}

func newWorker(pool *Pool) *jobWorker {
	return &jobWorker{
		pool: pool,
		job:  make(chan *Job),
		stop: make(chan bool),
	}
}