package scheduler

import (
	"gitee.com/h79/goutils/common"
	"gitee.com/h79/goutils/common/timer"
	"time"
)

type jobWorker struct {
	pool    *Pool
	job     chan *Job
	timeout time.Duration
	running common.RunningCheck
	stop    chan bool
}

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

func (w *jobWorker) run() {
	defer func() {
		w.pool.workerQuit()
	}()
	for {
		w.pool.workers <- w
		select {
		case job := <-w.job:
			res, err := timer.Call(w.timeout, func() (interface{}, error) {
				return job.Execute()
			})
			w.pool.jobDone(JobResult{JType: job.JType, JId: job.JId, Data: res, Err: err})

		case stop := <-w.stop:
			if stop {
				w.stop <- true
				return
			}
		}
	}
}

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