菠菜网站做首存十大最靠谱培训机构

func worker() {select {case <-c:// ... do some stuffcase <-time.After(30 *time.Second):return}
}

它创建了一个计时器，但返回的只是计时器关联的通道
如果不从返回的通道中接收值，即使超时发生后，计时器也不会被垃圾回收
这会导致计时器泄漏，特别是在循环中使用时会创建大量无法及时回收的计时器

改进方法 调用defer 进行stop

func worker() {timer := time.NewTimer(30 * time.Second)defer timer.Stop() // 确保定时器被清理
select {case <-c:// ... do some stuffcase <-timer.C:return}
}

Kubernetes中的改进方式： 重用定时器

在maxinflight.go的代码中，使用了wait.Until函数，其内部已经正确处理了定时器的创建和清理：
（接上篇 maxinflight.go 的源码略读）

func Until(f func(), period time.Duration, stopCh <-chan struct{}) {JitterUntil(f, period, 0.0, true, stopCh)
}
func JitterUntil(f func(), period time.Duration, jitterFactor float64, sliding bool, stopCh <-chan struct{}) {var t *time.Timervar sawTimeout boolfor {select {case <-stopCh:returndefault:}jitteredPeriod := periodif jitterFactor > 0.0 {jitteredPeriod = Jitter(period, jitterFactor)}if !sliding {t = resetOrReuseTimer(t, jitteredPeriod, sawTimeout)}func() {f()}()if sliding {t = resetOrReuseTimer(t, jitteredPeriod, sawTimeout)}// 注意这里重用了定时器select {case <-stopCh:returncase <-t.C:sawTimeout = true}
}
}