A worker pool for golang
Step 1: Create a Task before you start using it.
// An interface like Runable in JAVA
type Task interface {
Run() error
}
type myTask struct {
}
func (t *myTask) Run() error {
// do something here
return nil
}Step2: Create the workPool
p:=wpool.New() // create a workerPool with directExecutor and default max workers ..
// then start it
p.Start()
// submit some tasks
p.Submit(&myTask{})
// wait then stop
p.WaitThenStop()Custom workPool
func myExecutor(r Task) error {
return r.Run()
}
p:=wpool.NewWith(myExecutor, 1024, math.MaxInt64*time.Nanosecond, wpool.BlockWhenNoWorker)
p.Start()
p.Submit(...)
p.Stop()On my macOS High Sierra: 2.5 GHz Intel Core i7, 4 Core
goos: darwin
goarch: amd64
BenchmarkWorkerPool_SubmitOneWorkerNoIdleOneCPU-8 100 36199276 ns/op 13 B/op 1 allocs/op
BenchmarkWorkerPool_SubmitOneWorkerNoIdleMoreCPU-8 200000 10273 ns/op 8 B/op 1 allocs/op
BenchmarkWorkerPool_Submit16WorkerNoIdleOneCPU-8 50000 34704 ns/op 13 B/op 1 allocs/op
BenchmarkWorkerPool_Submit1024WorkerNoIdleOneCPU-8 50000 33809 ns/op 13 B/op 1 allocs/op
BenchmarkWorkerPool_Submit16WorkerNoIdleMoreCPU-8 3000000 543 ns/op 8 B/op 1 allocs/op
BenchmarkWorkerPool_Submit1024WorkerNoIdleMoreCPU-8 3000000 535 ns/op 8 B/op 1 allocs/op
BenchmarkWorkerPool_SubmitOneWorkerDefaultIdleMoreCPU-8 100000 10824 ns/op 8 B/op 1 allocs/op
BenchmarkWorkerPool_Submit1024WorkerDefaultIdleMoreCPU-8 3000000 589 ns/op 8 B/op 1 allocs/op
PASS