Versions in this module Expand all Collapse all v0 v0.2.1 Nov 1, 2024 v0.2.0 Sep 28, 2024 Changes in this version type WorkerPool + func (w *WorkerPool[IN, OUT]) DiscardWork() v0.1.0 Sep 27, 2024 Changes in this version + var EOS = fmt.Errorf("no more results available") + type WorkFunc func(in IN) (OUT, error) + type WorkerPool struct + func NewWorkerPool[IN, OUT any](workerCount int, f WorkFunc[IN, OUT]) WorkerPool[IN, OUT] + func (w *WorkerPool[IN, OUT]) Next() (OUT, error) + func (w *WorkerPool[IN, OUT]) Process(input IN) + func (w *WorkerPool[IN, OUT]) Stop()
Go to main page