mirror of
https://github.com/newnius/YAO-scheduler.git
synced 2025-06-07 14:21:55 +00:00
update fair
This commit is contained in:
parent
06c83484d5
commit
1e43396a2d
@ -112,13 +112,12 @@ func (scheduler *SchedulerPriority) Start() {
|
|||||||
}
|
}
|
||||||
scheduler.queue = append(scheduler.queue, Job{})
|
scheduler.queue = append(scheduler.queue, Job{})
|
||||||
|
|
||||||
|
preempted.Status = Created
|
||||||
copy(scheduler.queue[idx+1:], scheduler.queue[idx:])
|
copy(scheduler.queue[idx+1:], scheduler.queue[idx:])
|
||||||
scheduler.queue[idx] = preempted
|
scheduler.queue[idx] = preempted
|
||||||
log.Info(scheduler.queue)
|
log.Info(scheduler.queue)
|
||||||
|
|
||||||
delete(scheduler.jobs, preempted.Name)
|
delete(scheduler.jobs, preempted.Name)
|
||||||
|
|
||||||
preempted.Status = Created
|
|
||||||
}
|
}
|
||||||
scheduler.historyMu.Unlock()
|
scheduler.historyMu.Unlock()
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user