代码拉取完成,页面将自动刷新
package scheduler
import (
"gitee.com/h79/goutils/common/system"
"gitee.com/h79/goutils/common/timer"
"time"
)
type jobWorker struct {
pool *Pool
job chan *Job
timeout time.Duration
running system.RunningCheck
stop chan bool
}
func (w *jobWorker) start() {
w.running.GoRunning(w.run)
}
func (w *jobWorker) run() {
defer func() {
w.pool.workerQuit()
}()
w.pool.workerRunning()
for {
w.pool.workers <- w //把idle work放进去
select {
case job := <-w.job:
res, err := timer.Call(w.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
case <-system.Closed():
w.stop <- true
return
}
}
}
func newWorker(pool *Pool) *jobWorker {
return &jobWorker{
pool: pool,
job: make(chan *Job),
stop: make(chan bool),
}
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。