worker

Documentation

Index

• type Pool
  • func New(size int, enableLog bool) *Pool
  • func NewWithDepth(size, depth int, enableLog bool) *Pool
  • func (p *Pool) Add(job func())
  • func (p *Pool) AddWithDepth(depth int, job func())
  • func (p *Pool) Close()
  • func (p *Pool) Run()

Types

type Pool

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

Pool is the worker pool

func New

func New(size int, enableLog bool) *Pool

func NewWithDepth

func NewWithDepth(size, depth int, enableLog bool) *Pool

func (*Pool) Add

func (p *Pool) Add(job func())

func (*Pool) AddWithDepth

func (p *Pool) AddWithDepth(depth int, job func())

func (*Pool) Close

func (p *Pool) Close()

Close closes all workers

func (*Pool) Run

func (p *Pool) Run()

Run runs all jobs with worker pool