YAO/YAO-scheduler
1
0
Fork 0
mirror of https://github.com/newnius/YAO-scheduler.git synced 2025-12-15 16:16:44 +00:00
Code Issues Releases Wiki Activity

update FCFS scheduler

Browse Source
This commit is contained in:
Newnius
2020-08-14 20:16:04 +08:00
parent 53dfe27deb
commit 28533a9f63
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/scheduler_FCFS.go
View File

@@ -25,11 +25,11 @@ func (scheduler *SchedulerFCFS) 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() {
for { for {
log.Debug("Scheduling") log.Debug("Scheduling")
time.Sleep(time.Second * 5)
scheduler.schedulingMu.Lock() scheduler.schedulingMu.Lock()
if len(scheduler.schedulingJobs) >= scheduler.parallelism { if len(scheduler.schedulingJobs) >= scheduler.parallelism {