Versions in this module Expand all Collapse all v0 v0.1.0 Aug 20, 2026 Changes in this version + var ErrMinConcurrentCount = errors.New("concurrent count must be at least 1") + var ErrPondClosed = errors.New("pond is closed") + var ErrWorkerNotFound = errors.New("worker not found") + type NoReturn int + const None + type Pond struct + func NewPond[T any, E any]() *Pond[T, E] + func (p *Pond[T, E]) AddWork(workerID string, request T) (<-chan E, error) + func (p *Pond[T, E]) Close() + func (p *Pond[T, E]) MapResults[U any](workerID string, fn func(E) U) <-chan U + func (p *Pond[T, E]) MustRegisterWorker(id string, worker *Worker[T, E]) + func (p *Pond[T, E]) RegisterWorker(id string, worker *Worker[T, E]) error + func (p *Pond[T, E]) ResultChan(workerID string) <-chan E + type Worker struct + ConcurrentCount int + QueueSize uint + RequestChan chan T + ResultChan chan E + Work func(T) E + func MustNewWorker[T any, E any](work func(T) E, queueSize uint, concurrentCount int) *Worker[T, E] + func NewWorker[T any, E any](work func(T) E, queueSize uint, concurrentCount int) (*Worker[T, E], error) + func (w *Worker[T, E]) Validate() error
Go to main page