抢票小程序


抢票小程序

我们可以利用所学的内容来写一个简易的抢票小程序

fr multiprocessing import Process import json,time,os def search(): time.sleep(1) # 模拟网络io with open('db.txt',mode='rt',encoding='utf8') as f: res = json.load(f) print(f'还剩') def get(): with open('db.txt',mode='rt',encoding='utf8') as f: res = json.load(f) # print(f'还剩') time.sleep(1) # 模拟网络io if res['count'] > 0: res['count'] = 1 with open('db.txt',mode='wt',encoding='utf8') as f: json.dump(res,f) time.sleep(1.5) # 模拟网络io print(f'进程 抢票成功') else: print('票已经售空啦!!!!!!!!!!!') def task(): search() get() if __name__ == '__main__': for i in range(15): p = Process(target=task) p.start() p.join() db.txt

抢票小程序(优化)

之前的抢票小程序看似完善但实际上在数据的安全方面依旧存在着问题,因此我们可以使用进程锁来实现优化

进程锁

进程锁的本质则是把锁住的代码变成串行,它可以用lock.acquire和lock.release来实现

lock.acquire:锁住

lock.release:释放锁头

优化的抢票小程序

fr multiprocessing import Process,Lock import json,time,os def search(): time.sleep(1) # 模拟网络io with open('db.txt',mode='rt',encoding='utf8') as f: res = json.load(f) print(f'还剩') def get(): with open('db.txt',mode='rt',encoding='utf8') as f: res = json.load(f) # print(f'还剩') time.sleep(1) # 模拟网络io if res['count'] > 0: res['count'] = 1 with open('db.txt',mode='wt',encoding='utf8') as f: json.dump(res,f) print(f'进程 抢票成功') time.sleep(1.5) # 模拟网络io else: print('票已经售空啦!!!!!!!!!!!') def task(lock): search() # 锁住 lock.acquire() get() lock.release() # 释放锁头 if __name__ == '__main__': lock = Lock() # 写在主进程是为了让子进程拿到同一把锁. for i in range(15): p = Process(target=task,args=(lock,)) p.start() # p.join() # 进程锁 是把锁住的代码变成了串行 # join 是把所有的子进程变成了串行 # 为了保证数据的安全,串行牺牲掉效率.

上一篇:Windows11 微软Microsoft官方制作系统U盘方法,系统安装详细教程

下一篇:电气设备故障诊断法“六诊、九法、三先后、六先后”


Copyright © 2002-2019 k262电脑网 www.k262.cn 皖ICP备2020016292号
温馨提示:部分文章图片数据来源与网络,仅供参考!版权归原作者所有,如有侵权请联系删除!QQ:251442993 热门搜索 网站地图