生产者和消费者模型
Producer-Consumer的Python项目详细描述
- 长描述
来自producer\consumer.queuetool导入queueproducer
从producer_consumer.queuetool导入queueconsumer
从producer_consumer.queuetool导入queueconsumerprocesss
导入多处理
导入json
def test_func（数据）：
“””test function”””
return json.dumps({“result”: data})
def test（）：
“””test”””
process_list = []
producer = QueueProducer()
lock = multiprocessing.Lock()
for i in range(4):
p = QueueConsumerProcess(target=test_func, input_queue=producer.queue, filename=”123.json”,
name=”process%d” % i, lock=lock)
p.开始（）
处理列表。追加（p）
对于范围（1000000）内的i：
producer.produce(str(i))
打印（“制作完成”）
对于进程中的p列表：
p.stop()
p.join()
如果名称
test()
欢迎加入QQ群-->： 979659372
