job: 执行失败的任务重试的过程中,任务数限制也有效

如果有任务在重试,限制数点 1 个
pull/1/head
miraclesu 2017-03-17 11:28:34 +08:00
parent 7a9647b8aa
commit 127f02330d
1 changed files with 6 additions and 6 deletions

View File

@ -75,6 +75,12 @@ func (c *Cmd) GetID() string {
}
func (c *Cmd) Run() {
// 同时执行任务数限制
if c.Job.limit() {
return
}
defer c.Job.unlimit()
if c.Job.Retry <= 0 {
c.Job.Run()
return
@ -221,12 +227,6 @@ func (j *Job) unlimit() {
// Run 执行任务
func (j *Job) Run() bool {
// 同时执行任务数限制
if j.limit() {
return true
}
defer j.unlimit()
var (
cmd *exec.Cmd
proc *Process