parallel

func ForEach ¶

func ForEach(total int, n int, process Processor) error

ForEach processes data in parallel. total is the total number of items to process. n is the degree of parallelism. process is called with the index of the item being processed.

ParallelFor acts as a semaphore over a total WaitGroup fan-out, and also coalesces errors into a single error result.

If callers need process to return actual data, they should allocate a slice of the data they need, and assign to the slice index while processing. See ParallelForFiles for an example usage.