parallel

Feb 12, 2026

Changes in this version

+ func ProcessAll[T any, R any](workers int, items []T, processor func(T) R) []R

+ type ProgressReporter struct

+ func NewProgressReporter(inner status.Reporter, prefix string, total int) *ProgressReporter

+ func (r *ProgressReporter) Processed() int

+ func (r *ProgressReporter) RecordProgress(detail string)

+ func (r *ProgressReporter) Reset()

+ func (r *ProgressReporter) SetTotal(total int)

+ func (r *ProgressReporter) Update(message string)

+ type WorkerPool struct

+ func NewWorkerPool[T any, R any](workers int, processor func(T) R) *WorkerPool[T, R]

+ func (p *WorkerPool[T, R]) Close()

+ func (p *WorkerPool[T, R]) Results() <-chan R

+ func (p *WorkerPool[T, R]) Start()

+ func (p *WorkerPool[T, R]) Submit(item T)

+ func (p *WorkerPool[T, R]) Workers() int