Go 异步任务队列:Go Machinery
Machinery 是一个 Go 语言的异步任务队列和作业队列,基于分布式消息传递。类似 Python 的 Celery 框架。
Machinery 中的任务(或者作业)可通过多个 worker 在很多服务器上并发的执行,或者可在单个服务器上利用 Go 的协程运行多个 worker 进程。
任务的定义:
type AddTask struct{} func (t AddTask) Run(args []interface{}) (interface{}, error) { parsedArgs, err := machinery.ParseNumberArgs(args) if err != nil { return nil, err } add := func(args []float64) float64 { sum := 0.0 for _, arg := range args { sum += arg } return sum } return add(parsedArgs), nil } type MultiplyTask struct{} func (t MultiplyTask) Run(args []interface{}) (interface{}, error) { parsedArgs, err := machinery.ParseNumberArgs(args) if err != nil { return nil, err } multiply := func(args []float64) float64 { sum := 1.0 for _, arg := range args { sum *= arg } return sum } return multiply(parsedArgs), nil } // ... more tasks
任务注册:
tasks := map[string]machinery.Task{ "add": AddTask{}, "multiply": MultiplyTask{}, } app.RegisterTasks(tasks)
本文由用户 pjp 自行上传分享,仅供网友学习交流。所有权归原作者,若您的权利被侵害,请联系管理员。
转载本站原创文章,请注明出处,并保留原始链接、图片水印。
本站是一个以用户分享为主的开源技术平台,欢迎各类分享!