[pipeline] Releases time ticker when shrink goroutine exits

easegress-io · Dec 12, 2017 · 2c9c95d · 2c9c95d
1 parent 2cf6124
commit 2c9c95d
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/engine/pipeline.go b/src/engine/pipeline.go
@@ -296,9 +296,12 @@ func (scheduler *dynamicPipelineScheduler) spawn() {
 }
 
 func (scheduler *dynamicPipelineScheduler) shrink() {
+ ticker := time.NewTicker(time.Second)
+ defer ticker.Stop()
+
  for {
  select {
- case <-time.Tick(time.Second):
+ case <-ticker.C:
  scheduler.instancesLock.RLock()
 
  currentParallelism := uint32(len(scheduler.instances))