YAO/YAO-scheduler
1
0
Fork 0
mirror of https://github.com/newnius/YAO-scheduler.git synced 2025-06-07 14:21:55 +00:00
Code Issues Releases Wiki Activity

update fair

Browse Source
This commit is contained in:
Newnius 2020-06-03 17:22:56 +08:00
parent 912471de01
commit e43876b45c
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/scheduler_priority.go
View File

@ -27,6 +27,7 @@ func (scheduler *SchedulerPriority) Start() {
scheduler.history = []*Job{} scheduler.history = []*Job{}
scheduler.enabled = true scheduler.enabled = true
scheduler.parallelism = 1 scheduler.parallelism = 1
scheduler.schedulingJobs = map[string]bool{}
go func() { go func() {
flag := true flag := true
@ -98,6 +99,7 @@ func (scheduler *SchedulerPriority) Start() {
copy(scheduler.history[idx:], scheduler.history[idx+1:]) copy(scheduler.history[idx:], scheduler.history[idx+1:])
scheduler.history = scheduler.history[:len(scheduler.history)-1] scheduler.history = scheduler.history[:len(scheduler.history)-1]
} }
log.Info(idx, scheduler.history)
/* add back */ /* add back */
idx = len(scheduler.queue) idx = len(scheduler.queue)
@ -112,6 +114,9 @@ func (scheduler *SchedulerPriority) Start() {
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)
delete(scheduler.jobs, preempted.Name)
preempted.Status = Created preempted.Status = Created
} }