Versions in this module Expand all Collapse all v6 v6.8.0 Jun 13, 2024 v6.7.4 Sep 2, 2023 Changes in this version + type Pool struct + func NewPool(config PoolConfig) *Pool + func (p *Pool) PutWorkerInTheQueue(worker Worker) + func (p *Pool) QueueJob(job WorkerFunc) + func (p *Pool) Shutdown() + func (p *Pool) Start() + func (p *Pool) Wait() + func (p *Pool) WriteError(err error) + type PoolConfig struct + ErrorChan chan error + MaxWorkers int + type PoolOrchestrator interface + PutWorkerInTheQueue func(worker Worker) + QueueJob func(job WorkerFunc) + Shutdown func() + Start func() + Wait func() + WriteError func(err error) + type PoolWorker struct + func (w *PoolWorker) DoJob(job WorkerFunc) + func (w *PoolWorker) RejoinWorkerPool() + type Worker interface + DoJob func(job WorkerFunc) + RejoinWorkerPool func() + type WorkerFunc func() error
Go to main page