3：# 抢票示例 import json import time from multiprocessing import Process,Lock def search(i): with open('ticket',encoding='utf-8') as f: ticket = json.load(f) print('%s :当前的余票是%s张'%(i,ticket['count'])) def buy_ticket(i): with open('ticket',encoding='utf-8') as f: ticket = json.load(f) if ticket['count']>0: ticket['count'] -= 1 print('%s买到票了'%i) time.sleep(0.1) with open('ticket', mode='w',encoding='utf-8') as f: json.dump(ticket,f) def get_ticket(i,lock): search(i) with lock: # 代替acquire和release 并且在此基础上做一些异常处理,保证即便一个进程的代码出错退出了,也会归还钥匙 buy_ticket(i) if __name__ == '__main__': lock = Lock() # 互斥锁 for i in range(10): Process(target=get_ticket,args=(i,lock)).start() 1：# Lock解析
# import time # from multiprocessing import Lock,Process # def func(i,lock): # lock.acquire() # 拿钥匙 # print('被锁起来的代码%s'%i) # lock.release() # 还钥匙 # time.sleep(1) # # if __name__ == '__main__': # lock = Lock() # for i in range(10): # p = Process(target=func,args=(i,lock)) # p.start() 2：# from multiprocessing import Lock # 互斥锁 不能再同一个进程中连续acquire多次
# lock = Lock() # lock.acquire() # print(1) # lock.release() # lock.acquire() # print(2) # lock.release()
存票文件：
{"count": 0}
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之家整理，本文链接：https://www.bmabk.com/index.php/post/187723.html
