Versions in this module Expand all Collapse all v1 v1.0.0 Jul 18, 2021 Changes in this version + type Future struct + func (future *Future) Get(ctx context.Context) (interface{}, error) + type Pool struct + func NewPool(numWorkers int, proc processor) (*Pool, error) + func (p *Pool) AsyncProcess(ctx context.Context, i interface{}) (*Future, error) + func (p *Pool) Process(ctx context.Context, i interface{}) (interface{}, error) + func (p *Pool) SetPanicCallback(fn callbackFn) + func (p *Pool) Start() error + func (p *Pool) Stop() error + func (p *Pool) Wait()