I wrote my own in-process task queue in Go tailored to my needs. I needed auto-scaling and ability to connect different pools into a pipeline. https://github.com/cmitsakis/workerpool-go