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)

項目主頁：http://www.baiduhome.net/lib/view/home/1431304478747