parallel
is a tiny utility package for running functions in parallel with error handling.
You can very easily orchestrate highly complex function executions that run in parallel or ordered fashion,
combine both and get a single standard Go error back that supports functions from Go's errors package like
errors.Is
and errors.As
.
go get -u github.com/robinbraemer/parallel
Imagine you need to run multiple functions in parallel but some of them in order. It would be quiet code heavy to do so in a clean manner.
Luckily you can use the parallel
package to de-complicate this:
var fns [][]Fn
// ...
err := Ordered(
Parallel( // A
Parallel(fns[0]...), // 1
Parallel(fns[1]...), // 2
Parallel(fns[2]...), // 3
),
Parallel(fns[3]...), // B
Ordered(
Parallel(fns[5]...), // 4
Parallel(fns[6]...), // 5
), // C
).Do()
This is what happens:
- Ordered runs A, B, C in unparalleled order and returns the first error encountered
A
runs 3 slices of functions in parallel and block until all are finished- after
A
is doneB
runs functions in parallel - after
B
is doneC
runs functions in parallel - Ordered returns
That means 1-3
must complete before A
returns and B
is run and so forth.