高效处理大量计时器完成时运行函数的方法

知识点掌握了，还需要不断练习才能熟练运用。下面golang学习网给大家带来一个Golang开发实战，手把手教大家学习《高效处理大量计时器完成时运行函数的方法》，在实现功能的过程中也带大家重新温习相关知识点，温故而知新，回头看看说不定又有不一样的感悟！

我正在运行一项服务，用户上传持续时间，并且每次计时器用完时都必须重复执行一个函数。

例如，用户说“每 5 分钟运行一次”，则该函数必须每 5 分钟运行一次。这是通过 api 完成的。

对于少量计时器来说，这是微不足道的：

func doEvery(d time.Duration, f func(time.Time)) {
    for x := range time.Tick(d) {
        f(x) // Run the function every d duration
    }
}

我可以在 goroutine 中运行每个计时器，而且效果很好。我可以使用一些基本的 waitgroups 和同步功能来启动和停止所有操作。

但是如果我有数千或数百万个计时器怎么办？我可以为每个 goroutine 创建一个，但这感觉非常低效。这不是 erlang。

我应该有多个工作队列，按“延迟”排序，并简单地为更频繁的功能分配更多的工作人员吗？如果计时器尚未准备好，则会将其放回队列中。

这也不理想，因为工作人员忙于等待（弹出、检查时间、推送队列），而不是阻塞直到下一个计时器完成。

也许我可以有某种地图，按剩余持续时间进行索引？我不确定这里最好的方法是什么。

解决方案

我最近构建了这种解决方案，用户可以根据其间隔设置获得通知。我使用rabbitMQ和两个go脚本制作了一个工作池模型。其中一个 go 脚本使用下面的 cron 模块在消息队列中创建作业

https://github.com/robfig/cron

另一个 go 脚本是工作脚本，它使用消息队列并采取操作。 为了扩展，我正在运行工作脚本的多个实例。工作脚本的自动缩放可以通过rabbitMQ中的消息数量来完成

好了，本文到此结束，带大家了解了《高效处理大量计时器完成时运行函数的方法》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！