结合实际业务，整了一个 Go 的异步任务框架

链接在 https://github.com/jiajunhuang/gotasks

日常开发中，会发现很多异步任务会变的又大又长，其实其中很多任务是可以拆成 n 个子任务的，所以就整了这个框架，用法很简单，首先把任务分成 n 个子任务（不分用一个自然也是 ok 的），注册进去。接下来生产者 Enqueue 任务， 消费者消费任务。

注册的子任务会串成一个链，他们共用一个 map 来存储参数，因此第一个子任务可以修改参数并且返回，第二个子任务拿到的就是修改后的参数。

package main

import (
	"time"

	"github.com/jiajunhuang/gotasks"
)

const (
	uniqueJobName = "a-unique-job-name"
	redisURL      = "redis://127.0.0.1:6379/0"
	queueName     = "job-queue-name"
)

func worker() {
	gotasks.Run(queueName)
}

func main() {
	go worker()

	// register tasks
	handler1 := func(args gotasks.ArgsMap) (gotasks.ArgsMap, error) {
		time.Sleep(time.Duration(1) * time.Second)
		return args, nil
	}
	handler2 := func(args gotasks.ArgsMap) (gotasks.ArgsMap, error) {
		time.Sleep(time.Duration(1) * time.Second)
		return args, nil
	}
	gotasks.Register(uniqueJobName, handler1, handler2)

	// set broker
	gotasks.UseRedisBroker(redisURL, 100)

	// enqueue
	gotasks.Enqueue(queueName, uniqueJobName, gotasks.MapToArgsMap(map[string]interface{}{})) // or gotasks.StructToArgsMap
}