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

[bugfix] preempt, avoid deadlock

Browse Source
This commit is contained in:
Newnius 2020-08-13 21:17:34 +08:00
parent 63c121ae73
commit 3258e7d784
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/scheduler_priority.go
View File

@ -123,6 +123,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]
} }
scheduler.historyMu.Unlock()
/* add back */ /* add back */
idx = len(scheduler.queue) idx = len(scheduler.queue)
@ -149,8 +150,9 @@ func (scheduler *SchedulerPriority) Start() {
log.Info("before=", before, " after=", after) log.Info("before=", before, " after=", after)
time.Sleep(time.Millisecond * 100) time.Sleep(time.Millisecond * 100)
} }
} else {
scheduler.historyMu.Unlock()
} }
scheduler.historyMu.Unlock()
} }
} }
scheduler.queueMu.Unlock() scheduler.queueMu.Unlock()