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

goworkerpool

package module

Go to main page

Versions in this module

v0

v0.10.2

Feb 24, 2022

v0.10.1

Feb 24, 2022

v0.10.0

Apr 21, 2020

Changes in this version

+ const ErrorData

+ const ErrorDispatcherChannelFull

+ const ErrorDispatcherNoActionNoTask

+ const ErrorDispatcherWorkerCouldNotBeEnqueued

+ const ErrorEmbeddedErrors

+ const ErrorFullCapacityChannel

+ const ErrorKillAllWorkersInProgress

+ const ErrorNoDefaultWorkerFunction

+ const ErrorWaitInProgress

+ const ErrorWaitUntilInitialWorkersAreUpInProgress

+ const ErrorWorkerFuncPanic

+ const ErrorWorkerMaxTimeExceeded

+ const ErrorWorkerNilTask

+ const ErrorWorkerNoTaskFunc

+ const ErrorWorkerNotFound

+ const ErrorWorkerType

+ const ListenInProgress

+ const WorkerClosed

+ type Pool struct

+ func NewPool(initialWorkers int, maxOperationsInQueue int, logVerbose bool) *Pool

+ func NewPoolWithOptions(options PoolOptions) (*Pool, error)

+ func (st *Pool) AddCallback(callbackFn PoolCallback) error

+ func (st *Pool) AddTask(data interface{}) error

+ func (st *Pool) AddTaskCallback(data interface{}, callbackFn PoolCallback) error

+ func (st *Pool) AddWorker() error

+ func (st *Pool) AddWorkers(n int) error

+ func (st *Pool) GetPanicTasks() goconcurrentqueue.Queue

+ func (st *Pool) GetTotalWorkers() int

+ func (st *Pool) GetTotalWorkersInProgress() int

+ func (st *Pool) KillAllWorkers() error

+ func (st *Pool) KillAllWorkersAndWait() error

+ func (st *Pool) KillWorker() error

+ func (st *Pool) KillWorkers(n int) error

+ func (st *Pool) LateKillAllWorkers() error

+ func (st *Pool) LateKillWorker() error

+ func (st *Pool) LateKillWorkers(n int) error

+ func (st *Pool) PauseAllWorkers()

+ func (st *Pool) ResumeAllWorkers()

+ func (st *Pool) SafeWaitUntilNSuccesses(n int) error

+ func (st *Pool) SetKilledWorkerChan(ch chan int)

+ func (st *Pool) SetLogChan(ch chan PoolLog)

+ func (st *Pool) SetNewWorkerChan(ch chan int)

+ func (st *Pool) SetTotalWorkers(n int) error

+ func (st *Pool) SetWorkerFunc(fn PoolFunc)

+ func (st *Pool) StartWorkers() error

+ func (st *Pool) StartWorkersAndWait() error

+ func (st *Pool) Wait() error

+ func (st *Pool) WaitUntilInitialWorkersAreUp() error

+ func (st *Pool) WaitUntilNSuccesses(n int) error

+ type PoolCallback func(interface{})

+ type PoolError struct

+ func (st *PoolError) AddEmbeddedErrors(errors []error)

+ func (st *PoolError) Code() string

+ func (st *PoolError) Error() string

+ func (st *PoolError) GetEmbeddedErrors() []error

+ type PoolFunc func(interface{}) bool

+ type PoolLog struct

+ Code string

+ Error error

+ Message string

+ type PoolOptions struct

+ LogVerbose bool

+ MaxOperationsInQueue uint

+ MaxWorkers uint

+ NewWorkerChan chan int

+ TotalInitialWorkers uint

+ WaitUntilInitialWorkersAreUp bool