Использование очереди сообщений rabbitmq с несколькими потоками (Python Kombu)

У меня один обмен RabbitMQ с единственной очередью. Я хочу создать демона, который запускает несколько потоков и работает через эту очередь как можно быстрее.

«Работа» подразумевает взаимодействие с внешними службами, поэтому внутри каждого потребителя будет происходить изрядное количество блокировок. Таким образом, я хочу, чтобы несколько потоков работали с сообщениями из одной очереди.

Я могу добиться этого, используя очередь в моем основном потоке, а затем передавая входящую работу в пул других потоков, но есть ли способ запустить несколько потребителей, каждый в своем собственном многопоточном контексте?

7
задан Steve Mayne 28 June 2011 в 08:56
поделиться