workerpool

README

Worker Pool

A flexible Go worker pool model library using reflect.

Just toss all your jobs at it and it manages the concurrency using a pool of workers.

Look and Feel

// the function that does the job
func Print(num int) {
	time.Sleep(time.Duration(6-num) * time.Second)
	fmt.Println(num)
}

// fn and concurrency
wp, err := New(Print, 10)
if err != nil {
	panic("can't create workerqueue " + err.Error())
}
for i := 0; i <= 5; i++ {
	// send a job
	wp.Work(i)
}
// close the job queue and start waiting all the job to be finished
// you can ignore this if don't have to wait
wp.Wait()

For more examples, see main_test.go

Documentation

Index

• type Pool
  • func New(fn interface{}, concurrency int) (wp *Pool, err error)
  • func (wp *Pool) Close()
  • func (wp *Pool) Wait()
  • func (wp *Pool) Work(args ...interface{})

Types

type Pool

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

func New

func New(fn interface{}, concurrency int) (wp *Pool, err error)

Create a new worker pool.

func (*Pool) Close

func (wp *Pool) Close()

Close the job queue channel.

func (*Pool) Wait

func (wp *Pool) Wait()

Close the job queue channel and wait for all the jobs to be done.

func (*Pool) Work

func (wp *Pool) Work(args ...interface{})

Add a job to the job queue for processing.