pool

Documentation

Index

• type Pool
  • func NewPool(routines int, job func(input []byte)) *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 []byte)) *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.