worker

Documentation

Index

• type Pool
  • func NewPool(workers int) *Pool
  • func (p *Pool) Complete() <-chan struct{}
  • func (p *Pool) Enqueue(job func() error) error
  • func (p *Pool) Err() error
  • func (p *Pool) Start()
  • func (p *Pool) Stop()

Types

type Pool

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

Pool provides a set of workers for executing functions

func NewPool

func NewPool(workers int) *Pool

NewPool creates a pool with the specified number of workers. The pool will not begin accepting jobs until Start() is called.

func (*Pool) Complete

func (p *Pool) Complete() <-chan struct{}

Complete returns a channel that will be closed when all workers have finished

func (*Pool) Enqueue

func (p *Pool) Enqueue(job func() error) error

Enqueue adds a job to the pool.

func (*Pool) Err

func (p *Pool) Err() error

func (*Pool) Start

func (p *Pool) Start()

Start initializes the Pool to begin accepting and running jobs.

func (*Pool) Stop

func (p *Pool) Stop()

Stop prevents this pool from accepting new jobs.