Function Run

pkg/lib/parallel/parallel.go:26–58

Alternative: https://golang.org/pkg/sync/#WaitGroup (with error channel) Alternative: https://godoc.org/golang.org/x/sync/errgroup

(fn func() error, fns ...func() error)

// Alternative: https://godoc.org/golang.org/x/sync/errgroup

func Run(fn func() error, fns ...func() error) []error {
	allFns := append(fns, fn)

	errChannels := make([]chan error, len(allFns))
	for i := range errChannels {
		errChannels[i] = make(chan error)
	}

	for i := range allFns {
		fn := allFns[i]
		errChannel := errChannels[i]

		if fn == nil {
			errChannel <- nil
			continue
		}

		go func() {
			defer func() {
				if r := recover(); r != nil {
					errChannel <- errors.CastRecoverError(r)
				}
			}()
			errChannel <- fn()
		}()
	}

	errors := make([]error, len(allFns))
	for i := range allFns {
		errors[i] = <-errChannels[i]
	}
	return errors
}

func RunFirstErr(fn func() error, fns ...func() error) error {
	errs := Run(fn, fns...)