Lightweight Goroutine pool
Clients can submit jobs. Dispatcher takes job, and sends it to first available worker. When worker is done with processing job, will be returned back to worker pool.
Number of workers and Job queue size is configurable.
https://godoc.org/github.com/ivpusic/grpool
go get github.com/ivpusic/grpool
pool := NewPool(2, 10)
f := pool.Submit(func() interface{} {
time.Sleep(time.Second * 3)
return "ok"
})
fmt.Println(<-f.ResultChan)
package main
import (
"fmt"
"runtime"
"github.com/ivpusic/grpool"
)
func main() {
// number of workers, and size of job queue
pool := grpool.NewPool(100, 50)
defer pool.Release()
// how many jobs we should wait
pool.WaitCount(10)
// submit one or more jobs to pool
for i := 0; i < 10; i++ {
count := i
pool.Submit(func() interface{} {
// say that job is done, so we can know how many jobs are finished
defer pool.JobDone()
fmt.Printf("hello %d\n", count)
return nil
})
}
// wait until we call JobDone for all jobs
pool.WaitAll()
}
MIT