[FEATURE REQUEST] Support dynamic queue

[yangzhiw]

Is your feature request related to a problem? Please describe.
My usage scenario is that I want to put different businesses into different queues. Businesses change dynamically. When the program is running, it supports putting different data into different queues, and different queues support different threads. consumption.

[kamikazechaser]

Related to #850, #852

[yangzhiw]

Thank you. Another inquiry: Different queues use different coroutines to consume, and queue-level concurrency is supported; because looking at the source code now, it seems that there is only one processor to pull data.

[kamikazechaser]

That is also being addressed in #849