I read these messages into a concurrent queue, and...

# coroutines

[sailxjx]

I read these messages into a concurrent queue, and another thread (this is handled by the connect framework) will poll this queue and release the memory. sleep can avoid putting too many messages in the queue.