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
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

pool

package

Go to main page

Versions in this module

v0

v0.3.0

Feb 25, 2023

v0.2.0

Jan 17, 2023

Changes in this version

type ContextPool

+ func (p *ContextPool) WithCancelOnError() *ContextPool

type ResultContextPool

+ func (p *ResultContextPool[T]) WithCancelOnError() *ResultContextPool[T]

v0.1.0

Jan 2, 2023

Changes in this version

+ type ContextPool struct

+ func (g *ContextPool) Go(f func(ctx context.Context) error)

+ func (p *ContextPool) Wait() error

+ func (p *ContextPool) WithFirstError() *ContextPool

+ func (p *ContextPool) WithMaxGoroutines(n int) *ContextPool

+ type ErrorPool struct

+ func (p *ErrorPool) Go(f func() error)

+ func (p *ErrorPool) Wait() error

+ func (p *ErrorPool) WithContext(ctx context.Context) *ContextPool

+ func (p *ErrorPool) WithFirstError() *ErrorPool

+ func (p *ErrorPool) WithMaxGoroutines(n int) *ErrorPool

+ type Pool struct

+ func New() *Pool

+ func (p *Pool) Go(f func())

+ func (p *Pool) MaxGoroutines() int

+ func (p *Pool) Wait()

+ func (p *Pool) WithContext(ctx context.Context) *ContextPool

+ func (p *Pool) WithErrors() *ErrorPool

+ func (p *Pool) WithMaxGoroutines(n int) *Pool

+ type ResultContextPool struct

+ func (p *ResultContextPool[T]) Go(f func(context.Context) (T, error))

+ func (p *ResultContextPool[T]) Wait() ([]T, error)

+ func (p *ResultContextPool[T]) WithCollectErrored() *ResultContextPool[T]

+ func (p *ResultContextPool[T]) WithFirstError() *ResultContextPool[T]

+ func (p *ResultContextPool[T]) WithMaxGoroutines(n int) *ResultContextPool[T]

+ type ResultErrorPool struct

+ func (p *ResultErrorPool[T]) Go(f func() (T, error))

+ func (p *ResultErrorPool[T]) Wait() ([]T, error)

+ func (p *ResultErrorPool[T]) WithCollectErrored() *ResultErrorPool[T]

+ func (p *ResultErrorPool[T]) WithContext(ctx context.Context) *ResultContextPool[T]

+ func (p *ResultErrorPool[T]) WithFirstError() *ResultErrorPool[T]

+ func (p *ResultErrorPool[T]) WithMaxGoroutines(n int) *ResultErrorPool[T]

+ type ResultPool struct

+ func NewWithResults() *ResultPool[T]

+ func (p *ResultPool[T]) Go(f func() T)

+ func (p *ResultPool[T]) MaxGoroutines() int

+ func (p *ResultPool[T]) Wait() []T

+ func (p *ResultPool[T]) WithContext(ctx context.Context) *ResultContextPool[T]

+ func (p *ResultPool[T]) WithErrors() *ResultErrorPool[T]

+ func (p *ResultPool[T]) WithMaxGoroutines(n int) *ResultPool[T]