parallel

Documentation

Index

• func ProcessFiles[T any](files []string, workers int, fn func(path string) (T, bool)) []T
• func ProcessFilesWithLimit[T any](files []string, workers, limit int, fn func(path string) (T, bool)) []T

Functions

func ProcessFiles

func ProcessFiles[T any](files []string, workers int, fn func(path string) (T, bool)) []T

ProcessFiles runs a function on files in parallel with a worker pool. The function fn should return (result, include) where include indicates whether to include the result in the output slice.

func ProcessFilesWithLimit

func ProcessFilesWithLimit[T any](files []string, workers, limit int, fn func(path string) (T, bool)) []T

ProcessFilesWithLimit runs a function on files in parallel with a limit. Stops processing when limit results are collected.