workerpool

Documentation

Index

• Variables
• func NewWorkPool(size int) *workPool
• type Result
• type ResultHandler
• type WorkPool

Variables

var ErrSkipTask = errors.New("skip the task")

Functions

func NewWorkPool

func NewWorkPool(size int) *workPool

NewWorkPool creates a new worker pool which has "size" numbers of workers.

Types

type Result

type Result struct {
	Value interface{}
	Error error
}

type ResultHandler

type ResultHandler func(interface{}) error

type WorkPool

type WorkPool interface {
	Run(ResultHandler)
	Done() error
	AddTask(task) bool
}