Help us shape the future of Go! Take the 2026 Go Developer Survey

Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

ants

package module

Go to main page

Versions in this module

v1

v1.5.0

Sep 30, 2019

v1.4.0

Sep 30, 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")

+ func SpinLock() sync.Locker

+ 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

v1.0.1

Jul 26, 2019

v1.0.0

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