watermelo

第一次,站长亲自招 Gopher 了>>>

最近我在调查 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 } } } ``` 以下是应用程序的内存指标图:  在图中左侧,可以看到修复之前的内存消耗,右侧是修改后的内存消耗。分析器显示 `<-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 倍,这些都是阅读文档就能解决的问题。

本文由 GCTT 原创翻译,Go语言中文网 首发。也想加入译者行列,为开源做一些自己的贡献么?欢迎加入 GCTT!
翻译工作和译文发表仅用于学习和交流目的,翻译工作遵照 CC-BY-NC-SA 协议规定,如果我们的工作有侵犯到您的权益,请及时联系我们。
欢迎遵照 CC-BY-NC-SA 协议规定 转载,敬请在正文中标注并保留原文/译文链接和作者/译者等信息。
文章仅代表作者的知识和看法,如有不同观点,请楼下排队吐槽

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

4862 次点击 ∙ 1 赞

被以下专栏收入,发现更多相似内容

GCTT - Go 中文翻译组 GCTT - Go 中文翻译组 Go随笔 Go随笔

上一篇:译 | SOLID Go Design

下一篇:如何为 caddy 添写自定义插件

context 应用程序 计时器 prometheus

• 编辑
• 预览