银行存取钱
银行存取钱是同时对一个数据操作，容易造成数据混乱，解决方法是加锁
from multiprocessing import Process from time import sleep def get_money(num): # 取钱 num -= 1 print('子进程：', num) if __name__ == '__main__': money_num = 100 p = Process(target=get_money, args=(money_num,)) p.start() p.join() # 等子进程结束 print(money_num)
结果：
子进程： 99 100
数据不共享原因导致的
共享内存
from multiprocessing import Process, Value from time import sleep def get_money(num): # 取钱 num.value -= 1 print('子进程：', num.value) if __name__ == '__main__': money_num = Value('i', 100) p = Process(target=get_money, args=(money_num,)) p.start() p.join() print(money_num.value)
结果：
子进程： 99 99
要共享内存有多个方法，这里用Value，首先要导入，money_num=Value('i',100)这句话的Value接收两个参数，第一个是数据类型，第二个是这个类型的值，取值的时候要用x.value
银行取钱问题
from multiprocessing import Process, Value from time import sleep def get_money(num): # 取钱 for i in range(100): num.value -= 1 sleep(0.01) def put_money(num): # 存取 for i in range(100): num.value += 1 sleep(0.01) if __name__ == '__main__': money_num = Value('i', 100) p = Process(target=get_money, args=(money_num,)) p.start() # 取钱 p1 = Process(target=put_money, args=(money_num,)) p1.start() # 存取 p1.join() p.join() print(money_num.value)
多执行几次，有时候是100，有时候小于100，有时候大于100
锁 Lock
from multiprocessing import Process, Lock l = Lock() # 实例化 l.acquire() # 加锁。拿走钥匙，锁门，不让其他人进屋 l.release() # 释放锁。还钥匙，开门，允许其他人进屋
银行存取钱加锁
from multiprocessing import Process, Value, Lock from time import sleep def get_money(num, l): # 取钱 l.acquire() for i in range(100): num.value -= 1 sleep(0.01) l.release() def put_money(num, l): # 存取 for i in range(100): l.acquire() # 建议小范围的加锁 num.value += 1 l.release() sleep(0.01) if __name__ == '__main__': l = Lock() # 实例化锁 money_num = Value('i', 100) p = Process(target=get_money, args=(money_num, l)) p.start() # 取钱 p1 = Process(target=put_money, args=(money_num, l)) p1.start() # 存取 p1.join() p.join() print(money_num.value)
不管操作多少次都是100
遇见l.acquire()给数据加个锁，别的进程就不能操作这个数据了，直到l.release()之后其他的进程才可以操作锁，建议小范围内加锁
模拟 12306 强票
from multiprocessing import Process, Lock import time def check(i): with open('余票') as f: con = f.read() print('第%s个人查到余票还剩%s张' % (i, con)) def buy_ticket(i, l): l.acquire() # 拿钥匙，锁门 with open('余票') as f: con = int(f.read()) time.sleep(0.1) if con > 0: print('\033[31m 第%s个人买到票了\033[0m' % i) con -= 1 else: print('\033[32m 第%s个人没有买到票\033[0m' % i) time.sleep(0.1) # 是指 买完票后，把余票数量重写写入数据库的时间延迟 with open('余票', 'w') as f: f.write(str(con)) l.release() # 还钥匙，开门 if __name__ == '__main__': l = Lock() for i in range(10): p_ch = Process(target=check, args=(i + 1,)) p_ch.start() for i in range(10): p_buy = Process(target=buy_ticket, args=(i + 1, l)) p_buy.start()
新建一个 “余票” 的文件，写个12
执行结果
第1个人查到余票还剩12张 第2个人查到余票还剩12张 第3个人查到余票还剩12张 第4个人查到余票还剩12张 第5个人查到余票还剩12张 第6个人查到余票还剩12张 第7个人查到余票还剩12张 第8个人查到余票还剩12张 第9个人查到余票还剩12张 第10个人查到余票还剩12张 第1个人买到票了 第2个人买到票了 第3个人买到票了 第4个人买到票了 第5个人买到票了 第6个人买到票了 第7个人买到票了 第8个人买到票了 第9个人买到票了 第10个人买到票了
