concurrent

package

v1.10.1 Latest Latest Go to latest Published: Nov 22, 2025 License: Apache-2.0 Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

func ParallelForEach[T any](ctx context.Context, items []T, fn func(T) error, maxConcurrency int) error

ParallelForEach executes a function on each item in parallel

func ParallelMap[T, R any](ctx context.Context, items []T, fn func(T) (R, error), maxConcurrency int) ([]R, error)

ParallelMap executes a function on each item in parallel and returns results

type WorkerPool struct {
	// contains filtered or unexported fields
}

WorkerPool manages a pool of workers for concurrent operations

func NewWorkerPool(maxWorkers int) *WorkerPool

NewWorkerPool creates a new worker pool with the specified max workers

func (wp *WorkerPool) Do(ctx context.Context, fn func() error) error

Do executes a function with worker pool concurrency control