多威胁生产消费解决方案
queuing的Python项目详细描述
排队
多威胁生产消费解决方案
示例
importqueuingimporttimeimportlogginglogging.basicConfig(level=logging.DEBUG,format='%(asctime)s [%(levelname)5s] %(name)s%(message)s')@queuing.consumer(instances=5)defm1(no):time.sleep(1)print("m1 {}".format(no))queuing.broker.send('m2',{'no':no,'sqno':no*no,})[queuing.broker.send('m3',{'no':no,})foriinrange(0,10)]@queuing.consumer(instances=2)defm2(no,sqno):time.sleep(2)print("m2 {}{}".format(no,sqno))@queuing.consumer(instances=1)defm3(no):print("m3 {}".format(no))if__name__=='__main__':foriinrange(0,10):queuing.broker.send('m1',{'no':i})queuing.broker.loop()
欢迎加入QQ群-->： 979659372
