@@ -19,126 +19,54 @@ Golang异步工具集,启发自[JavaScript的`Promise`对象](https://develope
19
19
go get -u github.com/ghosind/go-async
20
20
```
21
21
22
- ## 入门
23
-
24
- ### 允许的函数
25
-
26
- 本工具集中大部分的工具方法接受一个任意参数及返回值的函数并执行,但为了最好的效果,建议将第一个参数设置为` context.Context ` 以接收信号,并将最后一个返回值的类型设置为` error ` 用于告知工具方法是否发生了错误。
27
-
28
- ### 同时运行所有函数直到结束
29
-
30
- ` All ` 方法可以用于异步执行所有的函数,它将所有函数的返回值包装为一个2维的any类型切片并返回,且返回一个错误类型告知调用方法执行时是否有函数发生了错误。
31
-
32
- 在` All ` 方法执行时,一旦有任意一个函数发生错误,它将立即结束并返回该错误,并且通过传递的上下文发生取消信号。
33
-
34
- ``` go
35
- out , err := async.All (func (ctx context .Context ) (int , error ) {
36
- return 0 , nil
37
- }, func (ctx context.Context ) (string , error )) {
38
- return " hello" , nil
39
- }/* , ...*/ )
40
- // out: [][]any{{0, <nil>}, {"hello", <nil>}}
41
- // err: <nil>
42
-
43
- out , err := async.All (func (ctx context .Context ) (int , error ) {
44
- return 0 , nil
45
- }, func (ctx context.Context ) (string , error )) {
46
- return " " , errors.New (" some error" )
47
- }/* , ...*/ )
48
- // out: [][]any{{}, {"", some error}}
49
- // err: function 1 error: some error
50
- ```
51
-
52
- 若在执行过程中,即使有某个函数发生错误也不希望结束整体的运行,可以使用` AllCompleted ` 方法。` AllCompleted ` 方法会等待所有函数都执行完成或发生错误后,才会结束并返回所有函数的执行结果。
22
+ 安装后在Go项目源码中导入。
53
23
54
24
``` go
55
- out , err := async.AllCompleted (func (ctx context .Context ) (int , error ) {
56
- return 0 , nil
57
- }, func (ctx context.Context ) (string , error ) {
58
- return " " , errors.New (" some error" )
59
- }/* , ...*/ )
60
- // out: [][]any{{0, nil}, {"", some error}}}
61
- // err: function 1 error: some error
25
+ import " github.com/ghosind/go-async"
62
26
```
63
27
64
- ### 获取第一个结束的函数结果
65
-
66
- 在执行一系列函数时,若希望得到第一个执行完成的函数结果,可以使用` Race ` 方法。` Race ` 方法将异步执行所有函数,并在第一个执行结束的函数完成时结束该方法的执行并返回结果至调用方法。在任意一个函数执行结束后,` Race ` 方法将通过上下文发送一个取消信号至其它函数。
67
-
68
- ` Race ` 方法返回以下三个返回值:
28
+ ## 入门
69
29
70
- - 2维执行结果列表;
71
- - 第一个执行完毕的函数在参数列表中的位置;
72
- - 第一个执行完毕的函数的错误。
30
+ 下面的代码中,通过` All ` 函数并发执行函数直到全部执行完成,并返回它们的返回结果。
73
31
74
32
``` go
75
- out , index , err := async.Race (func (ctx context .Context ) (int , error ) {
76
- request.Get (" https://example.com" )
33
+ out , err := async.All (func (ctx context .Context ) (int , error ) {
77
34
return 0 , nil
78
- }, func (ctx context.Context ) (string , error ) {
79
- time.Sleep (time.Second )
80
- return " test" , nil
81
- })
82
- // 第一个函数比第二个函数快的情况下:
83
- // out: []any{0, <nil>}, index: 0, err: <nil>
84
- //
85
- // 第二个函数比第二个函数快的情况下:
86
- // out: []any{"test", <nil>}, index: 1, err: <nil>
87
- ```
88
-
89
- ### 在并发限制下运行
90
-
91
- 为了在并发限制条件下异步运行所有函数,可以使用` Parallel ` 方法。` Parallel ` 方法接受一个非负数的并发值用于限制运行时可以达到的最大并发数量,当该值为0时表示对并发数量没有限制,运行效果等同于使用` All ` 函数。
92
-
93
- ``` go
94
- // 在并发限制数为2的条件下运行
95
- out , err := async.Parallel (2 , func (ctx context.Context ) (int , error ) {
96
- // Do something
97
- return 1 , nil
98
- }, func (ctx context.Context ) (string , error ) {
99
- // Do something
35
+ }, func () (string , error )) {
36
+ time.Sleep (100 * time.Millisecond )
100
37
return " hello" , nil
101
- }, func (ctx context.Context ) error {
102
- // Do something
103
- return nil
104
- }/* , ... */ )
105
- // out: [][]any{{1, <nil>}, {"hello", <nil>}, {<nil>}}
38
+ })
39
+ // out: [][]any{{0, <nil>}, {"hello", <nil>}}
106
40
// err: <nil>
107
41
```
108
42
109
- 在某一个函数发生错误时,` Parallel ` 也会结束并发送取消信号至其它函数。若不希望结束其它函数的执行,可以使用` ParallelCompleted ` 代替,它将执行全部函数直到所有函数都完成或发生错误。
110
-
111
- ### 持续运行直到发生错误
43
+ 本工具集中包含有超过十个异步控制方法,请前往[ Go Reference] ( https://pkg.go.dev/github.com/ghosind/go-async ) 获取详细的文档及示例。
112
44
113
- 通过 ` Forever ` 方法,可以持续运行某一函数直到该函数发生错误。 ` Forever ` 方法需要接受一个 ` ForeverFn ` 类型的方法用于执行,对于该类型的具体信息可以参考示例下方的描述。
45
+ ## 允许的函数
114
46
115
- ``` go
116
- err := Forever (func (ctx context.Context , next func (context.Context )) error {
117
- v := ctx.Value (" key" )
118
- if v != nil {
119
- vi := v.(int )
120
- if vi == 5 {
121
- return errors.New (" finish" )
122
- }
123
-
124
- fmt.Printf (" value: %d \n " , vi)
125
-
126
- next (context.WithValue (ctx, " key" , vi+1 ))
127
- } else {
128
- next (context.WithValue (ctx, " key" , 1 ))
129
- }
130
-
131
- return nil
132
- })
133
- // value: 1
134
- // value: 2
135
- // value: 3
136
- // value: 4
137
- // err: finish
138
- ```
139
-
140
- ` Forever ` 类型函数接受两个参数,第一个参数为从调用方法或上次调用传递来的上下文,第二个参数为为下次调用设置上下文的` next ` 函数。对于` ForeverFn ` 执行时,调用` next ` 函数设置上下文是一个可选的行为,且它只在第一次调用时生效。
47
+ 本工具集中大部分的工具方法接受一个任意参数及返回值的函数并执行,但为了最好的效果,建议将第一个参数设置为` context.Context ` 以接收信号,并将最后一个返回值的类型设置为` error ` 用于告知工具方法是否发生了错误。
141
48
142
- ### 自定义上下文
49
+ ## 自定义上下文
143
50
144
51
对于所有的工具方法,都有` XXXWithContext ` 版本(例如` AllWithContext ` 、` RaceWithContext ` 等),可以使用该版本传递自定义上下文。
52
+
53
+ ## 可用的工具方法
54
+
55
+ - [ ` All ` ] ( https://pkg.go.dev/github.com/ghosind/go-async#All )
56
+ - [ ` AllCompleted ` ] ( https://pkg.go.dev/github.com/ghosind/go-async#AllCompleted )
57
+ - [ ` Forever ` ] ( https://pkg.go.dev/github.com/ghosind/go-async#Forever )
58
+ - [ ` Parallel ` ] ( https://pkg.go.dev/github.com/ghosind/go-async#Parallel )
59
+ - [ ` ParallelCompleted ` ] ( https://pkg.go.dev/github.com/ghosind/go-async#ParallelCompleted )
60
+ - [ ` Race ` ] ( https://pkg.go.dev/github.com/ghosind/go-async#Race )
61
+ - [ ` Retry ` ] ( https://pkg.go.dev/github.com/ghosind/go-async#Retry )
62
+ - [ ` Seq ` ] ( https://pkg.go.dev/github.com/ghosind/go-async#Seq )
63
+ - [ ` Series ` ] ( https://pkg.go.dev/github.com/ghosind/go-async#Series )
64
+ - [ ` Times ` ] ( https://pkg.go.dev/github.com/ghosind/go-async#Times )
65
+ - [ ` TimesLimit ` ] ( https://pkg.go.dev/github.com/ghosind/go-async#TimesLimit )
66
+ - [ ` TimesSeries ` ] ( https://pkg.go.dev/github.com/ghosind/go-async#TimesSeries )
67
+ - [ ` Until ` ] ( https://pkg.go.dev/github.com/ghosind/go-async#Until )
68
+ - [ ` While ` ] ( https://pkg.go.dev/github.com/ghosind/go-async#While )
69
+
70
+ ## 许可
71
+
72
+ 本项目通过MIT许可发布,请通过license文件获取该许可的详细信息。
0 commit comments