[Feature] - Global Concurrency

[calebboyd]

Just found your library and perused the code - its exactly what I was looking for.

One thing I didn't see was the ability to control how many consumers can consume a queue.

Essentially, ensuring at most N activeWorkers for a queue (stream).