Skip to content

Commit 2a7c012

Browse files
committed
feat: make large channel to optimize all and parallel.
1 parent ffa27a0 commit 2a7c012

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

all.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ func all(parent context.Context, funcs ...AsyncFn) (int, error) {
4040
ctx, canFunc := context.WithCancel(parent)
4141
defer canFunc()
4242

43-
ch := make(chan executeResult)
43+
ch := make(chan executeResult, len(funcs))
4444
defer close(ch)
4545

4646
for i := 0; i < len(funcs); i++ {

parallel.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -45,8 +45,8 @@ func parallel(parent context.Context, concurrency int, funcs ...AsyncFn) (int, e
4545
ctx, canFunc := context.WithCancel(parent)
4646
defer canFunc()
4747

48-
ch := make(chan executeResult) // channel for result
49-
var conch chan empty // channel for concurrency limit
48+
ch := make(chan executeResult, len(funcs)) // channel for result
49+
var conch chan empty // channel for concurrency limit
5050

5151
// no concurrency limitation if the value of the number is 0
5252
if concurrency > 0 {

0 commit comments

Comments
 (0)