python3 多进程锁
作者：互联网
引入库
from multiprocessing import Lock
初始化
lock = Lock()
上锁
lock.acquire()
解锁
lock.release()
实例：
from multiprocessing import Process
import json
import time
from multiprocessing import Lock
def show(i):
with open('ticket') as f:
dic = json.load(f)#load直接打开文件, 不用read, loads操作字符串,需要read
print('余票: %s' % dic['ticket'])
def buy_ticket(i,lock):
lock.acquire() ##拿到钥匙进门,其他进程阻塞, acqurie和release之间的代码只能被一个进程执行
with open('ticket') as f:
dic = json.load(f)#load直接打开文件, 不用read, loads操作字符串,需要read
time.sleep(0.1)
if dic['ticket'] > 0 :
dic['ticket'] -=1
print('\033[32m%s买到票了\033[0m'%i) #console改为绿色
else:
print('\033[31m%s没有买到票了\033[0m'%i) #console改为红色
time.sleep(0.1)
with open('ticket', 'w') as f:
json.dump(dic,f) #修改json文件,减去被买去的票
lock.release() #释放钥匙
if __name__ == '__main__':
for i in range(10):
p = Process(target=show, args=(i,))
p.start()
lock = Lock() #产生钥匙
for i in range(10):
p = Process(target=buy_ticket, args=(i,lock))
p.start()
#没有进程锁是, 会出现多个用户都买到票的情况, 但是只有一张票
#进程锁
>>>
余票: 1
余票: 1
余票: 1
余票: 1
余票: 1
余票: 1
余票: 1
余票: 1
5买到票了
余票: 0
2没有买到票了
余票: 0
4没有买到票了
0没有买到票了
8没有买到票了
1没有买到票了
7没有买到票了
9没有买到票了
3没有买到票了
6没有买到票了
whatday
发布了57 篇原创文章 · 获赞 539 · 访问量 486万+
他的留言板
关注
标签：余票,买到,lock,dic,进程,import,ticket,python3 来源： https://blog.csdn.net/whatday/article/details/104071826