workerpool

Documentation

Index

• type Job
• type Pool
  • func NewPool(workerLen int) *Pool
  • func (pool *Pool) Join(job Job)
  • func (pool *Pool) Provide(ctx context.Context) interface{}
  • func (pool *Pool) Run()
• type Worker
  • func NewWorker() *Worker
  • func (worker *Worker) Run(wq chan chan Job)

Types

type Job

type Job interface {
	Do()
}

type Pool

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

func NewPool

func NewPool(workerLen int) *Pool

func (*Pool) Join

func (pool *Pool) Join(job Job)

func (*Pool) Provide

func (pool *Pool) Provide(ctx context.Context) interface{}

func (*Pool) Run

func (pool *Pool) Run()

type Worker

type Worker struct {
	JobQueue chan Job
	Quit     chan struct{}
}

func NewWorker

func NewWorker() *Worker

func (*Worker) Run

func (worker *Worker) Run(wq chan chan Job)