worker

README

worker

Simple worker pool utility for Go

Documentation

Index

• type Job
• type Pool
  • func NewPool(poolSize int) Pool
  • func (p *Pool) AddJob(j Job)
  • func (p *Pool) Close() error
  • func (p *Pool) Start()

Types

type Job

type Job interface {
	Process() error
}

type Pool

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

func NewPool

func NewPool(poolSize int) Pool

func (*Pool) AddJob

func (p *Pool) AddJob(j Job)

func (*Pool) Close

func (p *Pool) Close() error

func (*Pool) Start

func (p *Pool) Start()