黑松山资源网 Design By www.paidiu.com
抢票是并发执行
多个进程可以访问同一个文件
多个进程共享同一文件,我们可以把文件当数据库,用多个进程模拟多个人执行抢票任务
db.txt
{"count": 1}
并发运行,效率高,但竞争写同一文件,数据写入错乱,只有一张票,都卖成功给了10个人
#文件db.txt的内容为:{"count":1} #注意一定要用双引号,不然json无法识别 from multiprocessing import Process import time import json class Foo(object): def search(self, name): with open("db.txt", "r") as f_read: dic = json.load(f_read) time.sleep(1) # 模拟读数据的网络延迟 print("<%s>用户 查看剩余票数为 [%s]" % (name, dic["count"])) def get(self, name): with open("db.txt", "r") as f_read: dic = json.load(f_read) if dic["count"] > 0: dic["count"] -= 1 time.sleep(1) # 模拟写数据的网络延迟 with open("db.txt", "w") as f_write: json.dump(dic, f_write) print("<%s> 购票成功" % name) print("剩余票数为 [%s]" % dic["count"]) else: print("没票了,抢光了") def task(self, name): self.search(name) self.get(name) if __name__ == "__main__": obj = Foo() for i in range(1,11): # 模拟并发10个客户端抢票 p = Process(target=obj.task, args=("路人%s" % i,)) p.start()
总结:程序出现数据写入错乱
大家都查到票为1,都购票成功
<路人1>用户 查看剩余票数为 [1] <路人2>用户 查看剩余票数为 [1] <路人3>用户 查看剩余票数为 [1] <路人4>用户 查看剩余票数为 [1] <路人5>用户 查看剩余票数为 [1] <路人6>用户 查看剩余票数为 [1] <路人7>用户 查看剩余票数为 [1] <路人8>用户 查看剩余票数为 [1] <路人9>用户 查看剩余票数为 [1] <路人10>用户 查看剩余票数为 [1] <路人1> 购票成功 剩余票数为 [0] <路人2> 购票成功 剩余票数为 [0] <路人3> 购票成功 剩余票数为 [0] <路人4> 购票成功 剩余票数为 [0] <路人5> 购票成功 剩余票数为 [0] <路人6> 购票成功 剩余票数为 [0] <路人7> 购票成功 剩余票数为 [0] <路人8> 购票成功 剩余票数为 [0] <路人9> 购票成功 剩余票数为 [0] <路人10> 购票成功 剩余票数为 [0] 总结程序出现数据写入错乱
加锁处理:购票行为由并发变成了串行,牺牲了运行效率,但保证了数据安全
购票功能不应该并发执行,查票应该是并发执行的
查票准不准确不重要,有可能这张票就被别人买走
一个人写完以后,让另外一个人基于上一个人写的结果,再做购票操作
#把文件db.txt的内容重置为:{"count":1} from multiprocessing import Process from multiprocessing import Lock import time import json class Foo(object): def search(self, name): with open("db.txt", "r") as f_read: dic = json.load(f_read) time.sleep(1) # 模拟读数据的网络延迟 print("<%s>用户 查看剩余票数为 [%s]" % (name, dic["count"])) def get(self, name): with open("db.txt", "r") as f_read: dic = json.load(f_read) if dic["count"] > 0: dic["count"] -= 1 time.sleep(1) # 模拟写数据的网络延迟 with open("db.txt", "w") as f_write: json.dump(dic, f_write) print("<%s> 购票成功" % name) print("剩余票数为 [%s]" % dic["count"]) else: print("没票了,抢光了") def task(self, name, mutex): self.search(name) mutex.acquire() self.get(name) mutex.release() if __name__ == "__main__": mutex = Lock() obj = Foo() for i in range(1,11): # 模拟并发10个客户端抢票 p = Process(target=obj.task, args=("路人%s" % i, mutex)) p.start()
执行结果
<路人2>用户 查看剩余票数为 [1] <路人3>用户 查看剩余票数为 [1] <路人1>用户 查看剩余票数为 [1] <路人4>用户 查看剩余票数为 [1] <路人5>用户 查看剩余票数为 [1] <路人7>用户 查看剩余票数为 [1] <路人6>用户 查看剩余票数为 [1] <路人8>用户 查看剩余票数为 [1] <路人9>用户 查看剩余票数为 [1] <路人10>用户 查看剩余票数为 [1] <路人2> 购票成功 剩余票数为 [0] 没票了,抢光了 没票了,抢光了 没票了,抢光了 没票了,抢光了 没票了,抢光了 没票了,抢光了 没票了,抢光了 没票了,抢光了 没票了,抢光了
with lock
相当于lock.acquire(),执行完自代码块自动执行lock.release()
from multiprocessing import Process from multiprocessing import Lock import time import json class Foo(object): def search(self, name): with open("db.txt", "r") as f_read: dic = json.load(f_read) time.sleep(1) # 模拟读数据的网络延迟 print("<%s>用户 查看剩余票数为 [%s]" % (name, dic["count"])) def get(self, name): with open("db.txt", "r") as f_read: dic = json.load(f_read) if dic["count"] > 0: dic["count"] -= 1 time.sleep(1) # 模拟写数据的网络延迟 with open("db.txt", "w") as f_write: json.dump(dic, f_write) print("<%s> 购票成功" % name) print("剩余票数为 [%s]" % dic["count"]) else: print("没票了,抢光了") def task(self, name, mutex): self.search(name) with mutex: # 相当于lock.acquire(),执行完自代码块自动执行lock.release() self.get(name) if __name__ == "__main__": mutex = Lock() obj = Foo() for i in range(1,11): # 模拟并发10个客户端抢票 p = Process(target=obj.task, args=("路人%s" % i, mutex)) p.start()
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
黑松山资源网 Design By www.paidiu.com
广告合作:本站广告合作请联系QQ:858582 申请时备注:广告合作(否则不回)
免责声明:本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除!
免责声明:本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除!
黑松山资源网 Design By www.paidiu.com
暂无评论...
更新日志
2024年10月07日
2024年10月07日
- 群星《前途海量 电影原声专辑》[FLAC/分轨][227.78MB]
- 张信哲.1992-知道新曲与精丫巨石】【WAV+CUE】
- 王翠玲.1995-ANGEL【新艺宝】【WAV+CUE】
- 景冈山.1996-我的眼里只有你【大地唱片】【WAV+CUE】
- 群星《八戒 电影原声带》[320K/MP3][188.97MB]
- 群星《我的阿勒泰 影视原声带》[320K/MP3][139.47MB]
- 纪钧瀚《胎教古典音乐 钢琴与大提琴的沉浸时光》[320K/MP3][148.91MB]
- 刘雅丽.2001-丽花皇后·EMI精选王【EMI百代】【FLAC分轨】
- 齐秦.1994-黄金十年1981-1990CHINA.TOUR.LIVE精丫上华】【WAV+CUE】
- 群星.2008-本色·百代音乐人创作专辑【EMI百代】【WAV+CUE】
- 群星.2001-同步过冬AVCD【环球】【WAV+CUE】
- 群星.2020-同步过冬2020冀待晴空【环球】【WAV+CUE】
- 沈雁.1986-四季(2012梦田复刻版)【白云唱片】【WAV+CUE】
- 纪钧瀚《胎教古典音乐 钢琴与大提琴的沉浸时光》[FLAC/分轨][257.88MB]
- 《国语老歌 怀旧篇 3CD》[WAV/分轨][1.6GB]