| 注册
请输入搜索内容

热门搜索

Java Linux MySQL PHP JavaScript Hibernate jQuery Nginx
pjp
10年前发布

Go 异步任务队列:Go Machinery

Machinery 是一个 Go 语言的异步任务队列和作业队列,基于分布式消息传递。类似 Python 的 Celery 框架。

Machinery 中的任务(或者作业)可通过多个 worker 在很多服务器上并发的执行,或者可在单个服务器上利用 Go 的协程运行多个 worker 进程。

Go 异步任务队列:Go Machinery

任务的定义:

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)

项目主页:http://www.open-open.com/lib/view/home/1431304478747

 本文由用户 pjp 自行上传分享,仅供网友学习交流。所有权归原作者,若您的权利被侵害,请联系管理员。
 转载本站原创文章,请注明出处,并保留原始链接、图片水印。
 本站是一个以用户分享为主的开源技术平台,欢迎各类分享!
 本文地址:https://www.open-open.com/lib/view/open1431304478747.html
Go语言 Google Go/Golang开发