如何让消费者并发消费？

def createConsumer():
consumer = PushConsumer(gid) # 指定group-id
consumer.set_namesrv_addr(name_srv) # rocketmq队列接口地址（服务器ip:port)
consumer.subscribe(topic, callback) # 订阅
consumer.start() # 开启
if __name__=='__main__':
print('Parent process %s.' % os.getpid())
for i in range(5):
p = Process(target=createConsumer)
print('Run child process (%s)...' % (os.getpid()))
p.start()
while True:
time.sleep(3600)
为什么我写了多进程的消费程序，但是却并不执行

示されている createConsumer 関数と、5 つの multiprocessing.Process インスタンスを起動するループから始めます。Python クライアントの PushConsumer の起動処理と callback パスを調査し、報告された未実行を再現します。consumer が実行されない理由を特定し、動作する並行 consumer の例でその説明または fix を確認できれば完了です。

索引モデルが issue の本文から書いたものです。