Golang <-time.After()在计时器过期前不会被垃圾回收

watermelo · · 4138 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

最近我在调查 Go 应用程序中内存泄漏的问题,这个问题主要因为我没有正确的阅读文档。这是一段导致消耗了多个 Gbs 内存的代码: ```go func ProcessChannelMessages(ctx context.Context, in <-chan string, idleCounter prometheus.Counter) { for { start := time.Now() select { case s, ok := <-in: if !ok { return } // handle `s` case <-time.After(5 * time.Minute): idleCounter.Inc() case <-ctx.Done(): return } } } ``` 以下是应用程序的内存指标图: ![](https://raw.githubusercontent.com/studygolang/gctt-images/master/Golang-Timer-After-is-not-garbage-collected-before-expiry/1.png) 在图中左侧,可以看到修复之前的内存消耗,右侧是修改后的内存消耗。分析器显示 `<-time.After` 是内存泄漏的原因。直到我读到以下文档时,我才感到惊讶: > 在计时器触发之前,垃圾收集器不会回收 Timer。 所以 9Gb 的内存被定期垃圾回收变得非常必要了。我们在 channel 中每秒有 60k 个消息,在每个给定时刻分配大约 1800 万个计时器加上一些不确定数字的计时器等待被垃圾回收。 ```go func ProcessChannelMessages(ctx context.Context, in <-chan string, idleCounter prometheus.Counter) { idleDuration := 5 * time.Minute idleDelay := time.NewTimer(idleDuration) defer idleDelay.Stop() for { idleDelay.Reset(idleDuration) select { case s, ok := <-in: if !ok { return } // handle `s` case <-idleDelay.C: idleCounter.Inc() case <-ctx.Done(): return } } } ``` 微不足道的重构有助于将内存消耗减少 20 倍,这些都是阅读文档就能解决的问题。

via: https://medium.com/@oboturov/golang-time-after-is-not-garbage-collected-4cbc94740082

作者:Artem OBOTUROV  译者:watermelo  校对:polaris1119

本文由 GCTT 原创编译,Go语言中文网 荣誉推出


有疑问加站长微信联系(非本文作者))

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

4138 次点击  ∙  1 赞  
加入收藏 微博
被以下专栏收入,发现更多相似内容
4 回复  |  直到 2019-09-25 19:33:36
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传