Versions in this module Expand all Collapse all v1 v1.3.2 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
Go to main page