Versions in this module Expand all Collapse all v3 v3.1.1 Aug 23, 2016 Changes in this version + type Batch interface + Cancel func() + Queue func(fn WorkFunc) + QueueComplete func() + Results func() <-chan WorkUnit + WaitAll func() + type ErrCancelled struct + func (e *ErrCancelled) Error() string + type ErrPoolClosed struct + func (e *ErrPoolClosed) Error() string + type ErrRecovery struct + func (e *ErrRecovery) Error() string + type Pool interface + Batch func() Batch + Cancel func() + Close func() + Queue func(fn WorkFunc) WorkUnit + Reset func() + func New() Pool + func NewLimited(workers uint) Pool + type WorkFunc func(wu WorkUnit) (interface{}, error) + type WorkUnit interface + Cancel func() + Error func() error + IsCancelled func() bool + Value func() interface{} + Wait func()