workerpool

Jul 19, 2023

Changes in this version

+ var ErrStopped = fmt.Errorf("worker is stopped")

+ type Config struct

+ Concurrency int64

+ StopOnError bool

+ type Pool struct

+ func New(c *Config) *Pool[T]

+ func (p *Pool[T]) Do(ctx context.Context, fn WorkFunc[T]) error

+ func (p *Pool[T]) Done(ctx context.Context) ([]*Result[T], error)

+ type Result struct

+ Error error

+ Value T

+ type Void struct

+ type WorkFunc func() (T, error)