代码拉取完成，页面将自动刷新
简体中文 | English
Golang异步工具集，启发自JavaScript的Promise对象以及Node.js async包.
执行下面的命令以安装本工具集，由于依赖的关系，对Golang的版本需要为1.18及以后版本。
go get -u github.com/ghosind/go-async
本工具集中大部分的工具方法接受一个任意参数及返回值的函数并执行，但为了最好的效果，建议将第一个参数设置为context.Context以接收信号，并将最后一个返回值的类型设置为error用于告知工具方法是否发生了错误。
All方法可以用于异步执行所有的函数，它将所有函数的返回值包装为一个2维的any类型切片并返回，且返回一个错误类型告知调用方法执行时是否有函数发生了错误。
在All方法执行时，一旦有任意一个函数发生错误，它将立即结束并返回该错误，并且通过传递的上下文发生取消信号。
out, err := async.All(func (ctx context.Context) (int, error) {
return 0, nil
}, func (ctx context.Context) (string, error)) {
return "hello", nil
}/*, ...*/)
// out: [][]any{{0, <nil>}, {"hello", <nil>}}
// err: <nil>
out, err := async.All(func (ctx context.Context) (int, error) {
return 0, nil
}, func (ctx context.Context) (string, error)) {
return "", errors.New("some error")
}/*, ...*/)
// out: [][]any{{}, {"", some error}}
// err: function 1 error: some error
若在执行过程中，即使有某个函数发生错误也不希望结束整体的运行，可以使用AllCompleted方法。AllCompleted方法会等待所有函数都执行完成或发生错误后，才会结束并返回所有函数的执行结果。
out, err := async.AllCompleted(func (ctx context.Context) (int, error) {
return 0, nil
}, func (ctx context.Context) (string, error) {
return "", errors.New("some error")
}/*, ...*/)
// out: [][]any{{0, nil}, {"", some error}}}
// err: function 1 error: some error
在执行一系列函数时，若希望得到第一个执行完成的函数结果，可以使用Race方法。Race方法将异步执行所有函数，并在第一个执行结束的函数完成时结束该方法的执行并返回结果至调用方法。在任意一个函数执行结束后，Race方法将通过上下文发送一个取消信号至其它函数。
Race方法返回以下三个返回值：
out, index, err := async.Race(func (ctx context.Context) (int, error) {
request.Get("https://example.com")
return 0, nil
}, func (ctx context.Context) (string, error) {
time.Sleep(time.Second)
return "test", nil
})
// 第一个函数比第二个函数快的情况下：
// out: []any{0, <nil>}, index: 0, err: <nil>
//
// 第二个函数比第二个函数快的情况下：
// out: []any{"test", <nil>}, index: 1, err: <nil>
为了在并发限制条件下异步运行所有函数，可以使用Parallel方法。Parallel方法接受一个非负数的并发值用于限制运行时可以达到的最大并发数量，当该值为0时表示对并发数量没有限制，运行效果等同于使用All函数。
// 在并发限制数为2的条件下运行
out, err := async.Parallel(2, func (ctx context.Context) (int, error) {
// Do something
return 1, nil
}, func (ctx context.Context) (string, error) {
// Do something
return "hello", nil
}, func (ctx context.Context) error {
// Do something
return nil
}/* , ... */)
// out: [][]any{{1, <nil>}, {"hello", <nil>}, {<nil>}}
// err: <nil>
在某一个函数发生错误时，Parallel也会结束并发送取消信号至其它函数。若不希望结束其它函数的执行，可以使用ParallelCompleted代替，它将执行全部函数直到所有函数都完成或发生错误。
通过Forever方法，可以持续运行某一函数直到该函数发生错误。Forever方法需要接受一个ForeverFn类型的方法用于执行，对于该类型的具体信息可以参考示例下方的描述。
err := Forever(func(ctx context.Context, next func(context.Context)) error {
v := ctx.Value("key")
if v != nil {
vi := v.(int)
if vi == 5 {
return errors.New("finish")
}
fmt.Printf("value: %d\n", vi)
next(context.WithValue(ctx, "key", vi+1))
} else {
next(context.WithValue(ctx, "key", 1))
}
return nil
})
// value: 1
// value: 2
// value: 3
// value: 4
// err: finish
Forever类型函数接受两个参数，第一个参数为从调用方法或上次调用传递来的上下文，第二个参数为为下次调用设置上下文的next函数。对于ForeverFn执行时，调用next函数设置上下文是一个可选的行为，且它只在第一次调用时生效。
对于所有的工具方法，都有XXXWithContext版本（例如AllWithContext、RaceWithContext等），可以使用该版本传递自定义上下文。
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。
马建仓 AI 助手