work

Documentation

Index

• type Pool
  • func New() *Pool
  • func (p *Pool) Run(w Worker)
  • func (p *Pool) Shutdown()
  • func (p *Pool) Start()
• type Worker

Types

type Pool

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

Pool provides a pool of goroutines that can execute any Worker tasks that are submitted

func New

func New() *Pool

func (*Pool) Run

func (p *Pool) Run(w Worker)

Run submits work to the pool

func (*Pool) Shutdown

func (p *Pool) Shutdown()

Shutdown waits for all the goroutines to shutdown.

func (*Pool) Start

func (p *Pool) Start()

type Worker

type Worker interface {
	Task()
}

Worker must be implemented by types that want to use the worker pool.