parallel
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
.
Install
go get -u github.com/robinbraemer/parallel
Example
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 done B
runs functions in parallel
- after
B
is done C
runs functions in parallel
- Ordered returns
That means 1-3
must complete before A
returns and B
is run and so forth.