Enable concurrency in consumers

See this gist for an example script for testing the sleep behavior: https://gist.github.com/myobie/fe2df4b263f400d0de56