parallel

Documentation

Index

• func RunParallel(workers int, input []interface{}, ...) (resultError error)

Functions

func RunParallel

func RunParallel(
	workers int,
	input []interface{},
	process func(interface{}) (interface{}, error),
	collect func(int, interface{}) error,
) (resultError error)

RunParallel starts `workers` number of workers and feeds them with `input` data. Each worker calls `process`. Processed data is collected in the same order as the input and is passed in order to the `collect` callback. If an error occurs, the execution is stopped and the error returned. runParallel blocks until everything is done.