work

Documentation

Overview

Work manages a pool of go routines to perform work

Index

• type Pool
  • func New(maxWorkers int) *Pool
  • func (p *Pool) Run(w Worker)
  • func (p *Pool) Shutdown()
• type Worker

Types

type Pool

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

Pool provides a pool of goroutines that can execute any Worker tasks

func New

func New(maxWorkers int) *Pool

New creates a new work pool

func (*Pool) Run

func (p *Pool) Run(w Worker)

Run submits work to the pool

func (*Pool) Shutdown

func (p *Pool) Shutdown()

Shutdown waits for all the goroutines to shutdown

type Worker

type Worker interface {
	Task()
}

Worker interface is implemented by types that want to use the work pool