pool

Documentation

Index

• type Pool
  • func NewPool(routines int, job func(input interface{})) *Pool
  • func (p *Pool) Wait()
  • func (p *Pool) Work(c <-chan interface{})

Types

type Pool

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

Pool is a basic work pool - I didn't like any of the ones I found, so I made one

func NewPool

func NewPool(routines int, job func(input interface{})) *Pool

NewPool creates a new worker pool with a goroutine limit and a job function to execute on the incoming data

func (*Pool) Wait

func (p *Pool) Wait()

Wait waits until the pool is finished

func (*Pool) Work

func (p *Pool) Work(c <-chan interface{})

Work is a blocking call that starts the pool working on a data input channel