worker

Documentation

Index

• type WorkerJob
• type WorkerPool
  • func NewWorkerPool(numWorkers, queueSize int) *WorkerPool
  • func NewWorkerPoolWithResultsAndErrors(numWorkers, queueSize int) *WorkerPool
  • func (p *WorkerPool) Errorz() <-chan error
  • func (p *WorkerPool) ErrorzDone()
  • func (p *WorkerPool) ErrorzReady()
  • func (p *WorkerPool) Finish()
  • func (p *WorkerPool) Queue() chan<- WorkerJob
  • func (p *WorkerPool) QueueIgnore(j WorkerJob)
  • func (p *WorkerPool) Results() <-chan any
  • func (p *WorkerPool) ResultsDone()
  • func (p *WorkerPool) ResultsReady()
  • func (p *WorkerPool) Start()
  • func (p *WorkerPool) StartAndWait()
  • func (p *WorkerPool) Wait()

Types

type WorkerJob

type WorkerJob interface {
	Execute() (any, error)
}

type WorkerPool

type WorkerPool struct {
	// contains filtered or unexported fields
}

func NewWorkerPool

func NewWorkerPool(numWorkers, queueSize int) *WorkerPool

func NewWorkerPoolWithResultsAndErrors

func NewWorkerPoolWithResultsAndErrors(numWorkers, queueSize int) *WorkerPool

func (*WorkerPool) Errorz

func (p *WorkerPool) Errorz() <-chan error

func (*WorkerPool) ErrorzDone

func (p *WorkerPool) ErrorzDone()

func (*WorkerPool) ErrorzReady

func (p *WorkerPool) ErrorzReady()

func (*WorkerPool) Finish

func (p *WorkerPool) Finish()

func (*WorkerPool) Queue

func (p *WorkerPool) Queue() chan<- WorkerJob

func (*WorkerPool) QueueIgnore

func (p *WorkerPool) QueueIgnore(j WorkerJob)

func (*WorkerPool) Results

func (p *WorkerPool) Results() <-chan any

func (*WorkerPool) ResultsDone

func (p *WorkerPool) ResultsDone()

func (*WorkerPool) ResultsReady

func (p *WorkerPool) ResultsReady()

func (*WorkerPool) Start

func (p *WorkerPool) Start()

func (*WorkerPool) StartAndWait

func (p *WorkerPool) StartAndWait()

func (*WorkerPool) Wait

func (p *WorkerPool) Wait()