Go Machinery Go 异步任务队列 Go Machinery

blov • 4731 次点击    
这是一个分享于 的项目,其中的信息可能已经有所发展或是发生改变。
Machinery 是一个 Go 语言的异步任务队列和作业队列,基于分布式消息传递。类似 Python 的 [Celery](http://www.oschina.net/p/celery) 框架。 Machinery 中的任务(或者作业)可通过多个 worker 在很多服务器上并发的执行,或者可在单个服务器上利用 Go 的协程运行多个 worker 进程。 ![Example worker receives tasks](http://static.oschina.net/uploads/img/201505/11070408_cuip.png) 任务的定义: <pre class="brush:cpp ;toolbar: true; auto-links: false;">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</pre> 任务注册: <pre class="brush:cpp ;toolbar: true; auto-links: false;">tasks := map[string]machinery.Task{     &#34;add&#34;:      AddTask{},     &#34;multiply&#34;: MultiplyTask{}, } app.RegisterTasks(tasks)</pre>
授权协议:
BSD
开发语言:
Google Go 查看源码»
操作系统:
跨平台
4731 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传