ants

Jan 2, 2024

Changes in this version

+ var ErrInvalidLoadBalancingStrategy = errors.New("invalid load-balancing strategy")

+ var ErrInvalidPoolIndex = errors.New("invalid pool index")

+ type LoadBalancingStrategy int

+ const LeastTasks

+ const RoundRobin

+ type MultiPool struct

+ func NewMultiPool(size, sizePerPool int, lbs LoadBalancingStrategy, options ...Option) (*MultiPool, error)

+ func (mp *MultiPool) Cap() (n int)

+ func (mp *MultiPool) Free() (n int)

+ func (mp *MultiPool) FreeByIndex(idx int) (int, error)

+ func (mp *MultiPool) IsClosed() bool

+ func (mp *MultiPool) Reboot()

+ func (mp *MultiPool) ReleaseTimeout(timeout time.Duration) error

+ func (mp *MultiPool) Running() (n int)

+ func (mp *MultiPool) RunningByIndex(idx int) (int, error)

+ func (mp *MultiPool) Submit(task func()) (err error)

+ func (mp *MultiPool) Tune(size int)

+ func (mp *MultiPool) TuneMaxBlockingTasks(size int)

+ func (mp *MultiPool) Waiting() (n int)

+ func (mp *MultiPool) WaitingByIndex(idx int) (int, error)

+ type MultiPoolWithFunc struct

+ func NewMultiPoolWithFunc(size, sizePerPool int, fn func(interface{}), lbs LoadBalancingStrategy, ...) (*MultiPoolWithFunc, error)

+ func (mp *MultiPoolWithFunc) Cap() (n int)

+ func (mp *MultiPoolWithFunc) Free() (n int)

+ func (mp *MultiPoolWithFunc) FreeByIndex(idx int) (int, error)

+ func (mp *MultiPoolWithFunc) Invoke(args interface{}) (err error)

+ func (mp *MultiPoolWithFunc) IsClosed() bool

+ func (mp *MultiPoolWithFunc) Reboot()

+ func (mp *MultiPoolWithFunc) ReleaseTimeout(timeout time.Duration) error

+ func (mp *MultiPoolWithFunc) Running() (n int)

+ func (mp *MultiPoolWithFunc) RunningByIndex(idx int) (int, error)

+ func (mp *MultiPoolWithFunc) Tune(size int)

+ func (mp *MultiPoolWithFunc) TuneMaxBlockingTasks(size int)

+ func (mp *MultiPoolWithFunc) Waiting() (n int)

+ func (mp *MultiPoolWithFunc) WaitingByIndex(idx int) (int, error)

Jul 13, 2023

Changes in this version

+ func ReleaseTimeout(timeout time.Duration) error

Nov 15, 2022

Changes in this version

+ func SetDefaultAntsPool(size int, options ...Option)

Nov 3, 2022

Changes in this version

type Option

+ func WithDisablePurge(disable bool) Option

type Options

+ DisablePurge bool

May 23, 2022

Changes in this version

+ const DefaultAntsPoolSize

+ const DefaultCleanIntervalTime

+ const OPENED

+ var ErrInvalidPreAllocSize = errors.New("can not set up a negative capacity under PreAlloc mode")

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

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

+ var ErrTimeout = errors.New("operation timed out")

+ func Reboot()

+ type Logger interface

+ Printf func(format string, args ...interface{})

+ type Option func(opts *Options)

+ func WithExpiryDuration(expiryDuration time.Duration) Option

+ func WithLogger(logger Logger) 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

+ Logger Logger

+ MaxBlockingTasks int32

+ Nonblocking bool

+ PanicHandler func(interface{})

+ PreAlloc bool

type Pool

+ func (p *Pool) IsClosed() bool

+ func (p *Pool) MaxBlockingTasks() int

+ func (p *Pool) Reboot()

+ func (p *Pool) ReleaseTimeout(timeout time.Duration) error

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

+ func (p *Pool) Waiting() int

type PoolWithFunc

+ func (p *PoolWithFunc) IsClosed() bool

+ func (p *PoolWithFunc) MaxBlockingTasks() int

+ func (p *PoolWithFunc) Reboot()

+ func (p *PoolWithFunc) ReleaseTimeout(timeout time.Duration) error

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

+ func (p *PoolWithFunc) Waiting() int

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