Go 异步任务队列 YTask 发布，欢迎使用！

[a719114136]

YTask 是 Go 的异步任务队列，比起其他框架更方便快捷。

特性：

• 支持几乎所有类型，包括基本类型（ int, floalt, string...），数组切片，结构体以及复杂的结构体嵌套。
• 注册任务，调用任务一行代码完成，不需要对参数进行而外处理。
• 优雅的启动与结束方式，能 1 秒结束任务（如果你用过其他的框架（比如 gocelery，machinery ）会发现就算没有任务，他们也没法立即结束任务，而是需要等几秒）

GitHub

安装

go get github.com/gojuukaze/YTask/v2

注册任务

type User struct{
    ...
}
// 任务函数
func DemoFunc(a int, b float64, c []string, user User) (int, []User, string) {
    ....
    return ....
}

...

ser.Add("group1", "demo_func", DemoFunc)

调用任务

taskId, _ = client.Send("group1", "demo_func", 11, 22.2, []string{"bb", "cc"}, User{"hh",24})

获取结果

result, _ = client.GetResult(taskId, 2*time.Second, 300*time.Millisecond)
var a int
var b []User
var c string
a, _ = result.GetInt64(0)
// or
result.Get(1,&b)
// or
result.Gets(&a, &b, &c)

[a719114136]

打破 0 回复

[xjqxz2]

为啥不用 NSQ~

[a719114136]

@xjqxz2 算是理念不同吧。nsq 是消息队列，他传递的是消息，这个相当于 celery 的 go 实现，是任务队列，传递的是任务。
比较典型的应用场景就是:
消息队列，可以用来消费日志，把多台服务器的日志合并。但任务队列却不适合这种场景。
任务队列，可以用来处理异步的计算任务，比如用户购买了一件物品，需要计算用户的积分等，更新数据库，这时用任务队列比较合适。

消息队列侧重消息的吞吐，处理。任务队列，侧重任务执行，重试，结果返回。
消息队列可以代替任务队列，但还需要进行而外开发，在任务的执行上，提供的功能也不如任务队列。
任务队列更像远程函数调用，不过它和 thrift, grpc 也有不同，它不需要定义描述文件，也不是直接请求，而是借助消息队列传递任务信息

[a719114136]

@xjqxz2 在一定程度上，任务队列相当于消息队列在异步任务场景上的深度定制化开发。

[heavyrainn]

给个 star，之前用 machinary 感觉坑好多…后来渐渐不用了，改用 nats-streaming 自己实现异步任务队列了…

[a719114136]

@heavyrainn 哈哈，多谢～我也是觉得 machinary 不爽才自己写了个的

[dbskcnc]

与 uber cadence 比有何不同?