ants

Nov 21, 2023

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) 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) Waiting() (n int)

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

Jul 1, 2023

Changes in this version

+ func ReleaseTimeout(timeout time.Duration) error

Oct 11, 2022

Changes in this version

type Option

+ func WithDisablePurge(disable bool) Option

type Options

+ DisablePurge bool

May 7, 2022

Changes in this version

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

type Pool

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

+ func (p *Pool) Waiting() int

type PoolWithFunc

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

+ func (p *PoolWithFunc) Waiting() int

Mar 28, 2021

Changes in this version

type Pool

+ func (p *Pool) IsClosed() bool

type PoolWithFunc

+ func (p *PoolWithFunc) IsClosed() bool

May 27, 2020

Changes in this version

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

May 11, 2020

Changes in this version

+ type Logger interface

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

type Option

+ func WithLogger(logger Logger) Option

type Options

+ Logger Logger

Jan 25, 2020

Changes in this version

+ const OPENED

+ func Reboot()

type Pool

+ func (p *Pool) Reboot()

type PoolWithFunc

+ func (p *PoolWithFunc) Reboot()

Oct 13, 2019

Changes in this version

+ var ErrQueueIsFull = errors.New("the queue is full")

+ var ErrQueueLengthIsZero = errors.New("the queue length is zero")

Oct 5, 2019

Changes in this version

+ const DefaultAntsPoolSize

+ const DefaultCleanIntervalTime

Sep 27, 2019

Changes in this version

+ func SpinLock() sync.Locker

Sep 24, 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 ErrLackPoolFunc = errors.New("must provide function for pool")

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

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

+ func Cap() int

+ func Free() int

+ func Release()

+ func Running() int

+ func Submit(task func()) error

+ 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

+ type Pool struct

+ func NewPool(size int, options ...Option) (*Pool, error)

+ func (p *Pool) Cap() int

+ func (p *Pool) Free() int

+ func (p *Pool) Release()

+ func (p *Pool) Running() int

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

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

+ type PoolWithFunc struct

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

+ func (p *PoolWithFunc) Cap() int

+ func (p *PoolWithFunc) Free() int

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

+ func (p *PoolWithFunc) Release()

+ func (p *PoolWithFunc) Running() int

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