并发编程-多进程

　　2.需要自己加锁处理。

from multiprocessing import Process
from multiprocessing import Lock
import json
import time
import os
import random


def search():
    time.sleep(random.randint(1,3))  # 模拟网络延迟(查询环节)
    with open(‘ticket.json‘,encoding=‘utf-8‘) as f1:
        dic = json.load(f1)
        print(f‘{os.getpid()} 查看了票数,剩余{dic["count"]}‘)


def paid():
    with open(‘ticket.json‘,encoding=‘utf-8‘) as f1:

        dic = json.load(f1)
    if dic[‘count‘] > 0:
        dic[‘count‘] -= 1
        time.sleep(random.randint(1,3))  # 模拟网络延迟(购买环节)
        with open(‘ticket.json‘,encoding=‘utf-8‘,mode=‘w‘) as f1:
            json.dump(dic,f1)
        print(f‘{os.getpid()} 购买成功‘)


def task(lock):
    search()
    lock.acquire()
    paid()
    lock.release()

if __name__ == ‘__main__‘:
    mutex = Lock()
    for i in range(6):
        p = Process(target=task,args=(mutex,))
        p.start()

2.基于队列通信

进程之间互相隔离，要实现进程间通信(IPC，此机制帮我们自动处理锁的问题)，multiprocessing支持两种形式：队列和管道，这两种消息都是使用消息传递。

#1:起到缓冲的作用
#2:平衡生产力和消费力
#3:解耦(降低耦合性)

队列(管道+锁实现)：先进先出

（编辑：开发网_商丘站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!