ants

Aug 21, 2019

Changes in this version

+ var ErrLackPoolFunc = errors.New("must provide function for pool")

+ var ErrPoolOverload = errors.New("too many goroutines blocked on submit or Nonblocking is set")

+ type Option func(opts *Options)

+ func WithExpiryDuration(expiryDuration time.Duration) Option

+ func WithMaxBlockingTasks(maxBlockingTasks int) Option

+ func WithNonblocking(nonblocking bool) Option

+ func WithOptions(options Options) Option

+ func WithPanicHandler(panicHandler func(interface{})) Option

+ func WithPreAlloc(preAlloc bool) Option

+ type Options struct

+ ExpiryDuration time.Duration

+ MaxBlockingTasks int

+ Nonblocking bool

+ PanicHandler func(interface{})

+ PreAlloc bool

Apr 14, 2019

Changes in this version

+ const CLOSED

+ const DEFAULT_ANTS_POOL_SIZE

+ const DEFAULT_CLEAN_INTERVAL_TIME

+ var ErrInvalidPoolExpiry = errors.New("invalid expiry for pool")

+ var ErrInvalidPoolSize = errors.New("invalid size for pool")

+ var ErrPoolClosed = errors.New("this pool has been closed")

+ func Cap() int

+ func Free() int

+ func Release()

+ func Running() int

+ func Submit(task func()) error

+ type Pool struct

+ PanicHandler func(interface{})

+ func NewPool(size int) (*Pool, error)

+ func NewTimingPool(size, expiry int) (*Pool, error)

+ func (p *Pool) Cap() int

+ func (p *Pool) Free() int

+ func (p *Pool) Release() error

+ func (p *Pool) Running() int

+ func (p *Pool) Submit(task func()) error

+ func (p *Pool) Tune(size int)

+ type PoolWithFunc struct

+ PanicHandler func(interface{})

+ func NewPoolWithFunc(size int, pf func(interface{})) (*PoolWithFunc, error)

+ func NewTimingPoolWithFunc(size, expiry int, pf func(interface{})) (*PoolWithFunc, error)

+ func (p *PoolWithFunc) Cap() int

+ func (p *PoolWithFunc) Free() int

+ func (p *PoolWithFunc) Invoke(args interface{}) error

+ func (p *PoolWithFunc) Release() error

+ func (p *PoolWithFunc) Running() int

+ func (p *PoolWithFunc) Tune(size int)

+ type Worker struct

+ type WorkerWithFunc struct