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

zdpgo_pool_goroutine

package module

Go to main page

Versions in this module

v0

v0.1.2

Aug 11, 2022

v0.1.1

Aug 3, 2022

Changes in this version

+ func NewSpinLock() sync.Locker

+ func RunBatchArgTask(poolSize int, funcObj func(arg T), args []T)

+ func RunBatchTask(funcList []func())

v0.1.0

Jul 8, 2022

Changes in this version

+ const CLOSED

+ const DefaultAntsPoolSize

+ const DefaultCleanIntervalTime

+ const OPENED

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

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

+ 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")

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

+ func Cap() int

+ func Free() int

+ func Reboot()

+ func Release()

+ func Running() int

+ func Submit(task func()) error

+ 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 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) IsClosed() bool

+ func (p *Pool) Reboot()

+ func (p *Pool) Release()

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

+ func (p *Pool) Running() int

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

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

+ func (p *Pool) Waiting() 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) IsClosed() bool

+ func (p *PoolWithFunc) Reboot()

+ func (p *PoolWithFunc) Release()

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

+ func (p *PoolWithFunc) Running() int

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

+ func (p *PoolWithFunc) Waiting() int