This is a goroutine pool library in the Go for easier handling and termination.
Installation
go get github.com/0x5010/gpool
Requirements
- Need at least
go1.7or newer.
Usage
Create and run a gpool:
var fn1, fn2 func() // the function which you want to execute, anonymous functions form closures is better
var fn3, fn4 func(ctx context.Context) // with context, will canceled when pool stop
var limit, jobCount int // the number of goroutine and job
var wait bool // whether blocking
gp := gpool.New(limit, jobCount, wait)
gp.AddJob(fn1)
gp.AddJob(fn2)
gp.AddJobWithCtx(fn3)
gp.AddJobWithCtx(fn4)
if wait {
gp.Wait()
}termination:
gp.Stop()
...