From 28533a9f6397b3079340dd5dc39571d2971cdc72 Mon Sep 17 00:00:00 2001 From: Newnius Date: Fri, 14 Aug 2020 20:16:04 +0800 Subject: [PATCH] update FCFS scheduler --- src/scheduler_FCFS.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/scheduler_FCFS.go b/src/scheduler_FCFS.go index f2d3e71..0a684d0 100644 --- a/src/scheduler_FCFS.go +++ b/src/scheduler_FCFS.go @@ -25,11 +25,11 @@ func (scheduler *SchedulerFCFS) Start() { scheduler.history = []*Job{} scheduler.enabled = true scheduler.parallelism = 1 + scheduler.schedulingJobs = map[string]bool{} go func() { for { log.Debug("Scheduling") - time.Sleep(time.Second * 5) scheduler.schedulingMu.Lock() if len(scheduler.schedulingJobs) >= scheduler.parallelism {