python_并发编程——锁

import time
import json
from multiprocessing import Process

class Show(Process):    #查
    def run(self):
        with open(‘ticket‘) as f:
            dic = json.load(f)
            print("余票：{}".format(dic[‘ticket‘]))

class Buy_ticket(Process):  #买
    def __init__(self,name):
        super().__init__()
        self.name = name
    def run(self):
        with open(‘ticket‘) as f:
            dic = json.load(f)
            time.sleep(0.1) #模拟网络延迟
        if dic[‘ticket‘] > 0:
            dic[‘ticket‘] -=1
            print(‘{}买到票了~~~‘.format(self.name))
            time.sleep(0.1) #模拟网络延迟
            with open(‘ticket‘,‘w‘) as f:
                json.dump(dic,f)
        else:
            print(‘{}没买到票!!!‘.format(self.name))
if __name__ == ‘__main__‘:
    for i in range(10):
        q1 = Show()
        q1.start()
    for i in range(10):
        i = str(i)
        q2 = Buy_ticket(i)
        q2.start()

import time
import json
from multiprocessing import Process
from multiprocessing import Lock

class Show(Process):    #查
    def run(self):
        with open(‘ticket‘) as f:
            dic = json.load(f)
            print("余票：{}".format(dic[‘ticket‘]))

class Buy_ticket(Process):  #买
    def __init__(self,name,lock):   #接收锁对象
        super().__init__()
        self.name = name
        self.lock = lock
    def run(self):
        self.lock.acquire()     #拿钥匙进门
        with open(‘ticket‘) as f:
            dic = json.load(f)
            time.sleep(0.1) #模拟网络延迟
        if dic[‘ticket‘] > 0:
            dic[‘ticket‘] -=1
            print(‘{}买到票了~~~‘.format(self.name))
            time.sleep(0.1) #模拟网络延迟
            with open(‘ticket‘,‘w‘) as f:
                json.dump(dic,f)
        else:
            print(‘{}没买到票!!!‘.format(self.name))
        self.lock.release()     #还钥匙
if __name__ == ‘__main__‘:
    for i in range(10):
        q1 = Show()
        q1.start()
    lock = Lock()   #定义一个锁对象
    for i in range(10):
        i = str(i)
        q2 = Buy_ticket(i,lock) #将锁对象传入子进程
        q2.start()