from multiprocessing import Process import json,time,os def search(): time.sleep(1) with open('db.txt','rt',encoding='utf8') as f: res=json.load(f) print(f'还剩{res["count"]}') def get(): with open('db.txt',encoding='utf8')as f: res=json.load(f) time.sleep(1) if res['count']>0: res['count']-=1 with open('db.txt','wt',encoding='utf8')as f: json.dump(res,f) time.sleep(1.5) #模拟网络io print(f'进程{os.getpid()}抢票成功') else: print('票已经售空了') def task(): search() get() if __name__ == '__main__': for i in range(10): p=Process(target=task) p.start() p.join() # 为了保证数据的安全,要牺牲掉效率.
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。