Why does the consumer not work when using the thread pool to consume events?

[AllenHuang]

I have a large number of consumers, if creating a separate thread for each consumer is not a good idea. So I want to use thread pool to consume all events. But a strange implementation happened, the consumer only consumed a small amount of data and was blocked all the time. No new consumers consume any events.

Here is an example of my code:

This is what the console prints:

What did i do wrong?