Commit 9b39896d authored by Andreas Bigger's avatar Andreas Bigger

Remove mutex and reorder metric updates

parent c323b81e
...@@ -22,7 +22,6 @@ type SchedulerMetricer interface { ...@@ -22,7 +22,6 @@ type SchedulerMetricer interface {
} }
type Scheduler struct { type Scheduler struct {
executorMutex sync.Mutex
logger log.Logger logger log.Logger
coordinator *coordinator coordinator *coordinator
m SchedulerMetricer m SchedulerMetricer
...@@ -56,17 +55,13 @@ func NewScheduler(logger log.Logger, m SchedulerMetricer, disk DiskManager, maxC ...@@ -56,17 +55,13 @@ func NewScheduler(logger log.Logger, m SchedulerMetricer, disk DiskManager, maxC
} }
func (s *Scheduler) ThreadActive() { func (s *Scheduler) ThreadActive() {
s.executorMutex.Lock()
defer s.executorMutex.Unlock()
s.m.DecIdleExecutors()
s.m.IncActiveExecutors() s.m.IncActiveExecutors()
s.m.DecIdleExecutors()
} }
func (s *Scheduler) ThreadIdle() { func (s *Scheduler) ThreadIdle() {
s.executorMutex.Lock()
defer s.executorMutex.Unlock()
s.m.DecActiveExecutors()
s.m.IncIdleExecutors() s.m.IncIdleExecutors()
s.m.DecActiveExecutors()
} }
func (s *Scheduler) Start(ctx context.Context) { func (s *Scheduler) Start(ctx context.Context) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment