rabbitmq - 使用 Pika 实现消费者线程

Question

我正在按照下面的示例使用 Pika 库实现线程使用者：https ://github.com/pika/pika/blob/master/examples/basic_consumer_threaded.py 。

现在一切正常，但我想知道这个解决方案是否会在以后引起问题。

特别是，他们将所有线程添加到一个数组中，而在处理完消息后没有删除它们。

 thrds.append(t)

# Wait for all to complete
for thread in threads:
    thread.join()

虽然我理解原因是实现优雅退出，但我不确定将来是否会出现问题，是否有更好的方法来实现线程消费者？

标签： rabbitmqpika