workers

WORKERS

workers pool for Golang

Install

go get -u github.com/aacfactory/workers

Usage

Create worker command handler

type Handler struct {}

func (h *Handler) Handle(command interface{}) {
    // todo: handle command
}

New workers and execute command

workers := workers.New(&Handler{})


if ok := workers.Execute(struct{}); !ok {
    // todo: handle 'no workers remain' or 'closed'
}

workers.Close()

Benchmark

Handler used in benchmark is sleeping 50 millisecond as handling command.

goos: windows
goarch: amd64
pkg: github.com/aacfactory/workers
cpu: AMD Ryzen 9 3950X 16-Core Processor
BenchmarkNewWorkers
    worker_benchmark_test.go:37: total 1 accepted 1
    worker_benchmark_test.go:37: total 100 accepted 100
    worker_benchmark_test.go:37: total 10000 accepted 10000
    worker_benchmark_test.go:37: total 266420 accepted 266420
    worker_benchmark_test.go:37: total 834958 accepted 834958
    worker_benchmark_test.go:37: total 1104766 accepted 1104766
BenchmarkNewWorkers-32           1104766               953.7 ns/op            25
 B/op          1 allocs/op
PASS

Thanks

• valyala/fasthttp