Usage

go get github.com/mdouchement/workerpool

package mainimport ("fmt""github.com/mdouchement/workerpool")funcmain() {// It is not mandatory to implement all *Func.job:=&workerpool.Job{// Triggered when the job's status changeOnStatusChangeFunc:func(j*workerpool.Job)error {fmt.Println("Status changed to:",j.Status())returnnil},// Before starting jobBeforeFunc:func(j*workerpool.Job)error {fmt.Println("Before starting job")returnnil},// Task to performActionFunc:func(j*workerpool.Job)error {fmt.Println("Starting job")returnnil},// When job is completedAfterFunc:func(j*workerpool.Job)error {fmt.Println("After job")returnnil},// Triggered when workerpool.Cancel("job_id")// You can use j.Context() to forward cancellation signal.CancelFunc:func(j*workerpool.Job)error {fmt.Println("Execute cleanup function")returnnil},// Triggered when an error or panic occurred.ErrHandler:func(j*workerpool.Job,errerror,panicbool) {// Do something with the error (and j.Context()).},}id:=workerpool.Send(job)fmt.Println("Job id:",id)}

License

Contributing

# Formatfind. -name'*.go' -not -path'./vendor*' -exec gofmt -s -w {}\;# Lintgometalinter --config=gometalinter.json ./...