为了同时运行这两个函数，一些多线程方法需要按顺序运行。请查看here中的一些python示例。
这是用Process类修改的代码。它也可以使用线程或从操作系统显式运行它。

import pika
from multiprocessing import Process

def callback():
    print 'callback got data'

class c1():
    def __init__(self):
        self.connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
        self.channel = self.connection.channel()
        self.channel.exchange_declare(exchange='e1', durable='true', type='topic')
        result = self.channel.queue_declare(durable='false', queue='q1')
        queue_name = result.method.queue
        binding_key = "b1"
        self.channel.queue_bind(exchange='e1', queue=queue_name, routing_key=binding_key)
        self.channel.basic_consume(callback,queue=queue_name,no_ack=False)

    def run(self):
        self.channel.start_consuming()

class c2():
    def __init__(self):
        self.connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
        self.channel = self.connection.channel()
        self.channel.exchange_declare(exchange='e2', durable='true', type='topic')
        result = self.channel.queue_declare(durable='false', queue='q2')
        queue_name = result.method.queue
        binding_key = "b2"
        self.channel.queue_bind(exchange='e1', queue=queue_name, routing_key=binding_key)

        self.channel.basic_consume(callback,queue=queue_name,no_ack=False)

    def run(self):
        self.channel.start_consuming()

if __name__ == '__main__':
    subscriber_list = []
    subscriber_list.append(c1())
    subscriber_list.append(c2())

    # execute
    process_list = []
    for sub in subscriber_list:
        process = Process(target=sub.run)
        process.start()
        process_list.append(process)

    # wait for all process to finish
    for process in process_list:
        process.join()

您可以使用一个连接和一个通道接收来自多个队列的消息。pika python模块内置了测试代码，可使用一个阻塞连接和一个通道进行测试（仅供参考，此test code is from 2015）。

下面是pika python模块的测试代码，它测试如何使用一个阻塞连接和一个通道从多个队列中获取消息：https://github.com/pika/pika/blob/1.3.0/tests/acceptance/blocking_adapter_test.py#L2072-L2172。
由于我自己的顽固原因，我也写了类似的代码，使用一个阻塞连接和一个通道和两个队列，并验证了这也工作。