from multiprocessing import Process,Lock
import timedef 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 -= 1else: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()

from multiprocessing import Process,Semaphore
import timedef func(i,sem):sem.acquire()print('第%s个人进入小黑屋,拿了钥匙锁上门' % i)time.sleep(1)print('第%s个人出去小黑屋,还了钥匙打开门' % i)sem.release()if __name__ == '__main__':sem = Semaphore(5)# 初始化了一把锁5把钥匙，也就是说允许5个人同时进入小黑屋# 之后其他人必须等待，等有人从小黑屋出来，还了钥匙，才能允许后边的人进入for i in range(20):p = Process(target=func,args=(i,sem,))p.start()

def tra(e):'''信号灯函数'''while 1:# 红绿灯得一直亮着，要么是红灯要么是绿灯if e.is_set():# True,代表绿灯亮,那么此时代表可以过车time.sleep(5)# 所以在这让灯等5秒钟，这段时间让车过print('\033[31m 红灯亮! \033[0m')# 绿灯亮了5秒后应该提示到红灯亮e.clear()# 把is_set设置为Falseelse:time.sleep(5)# 此时代表红灯亮了，此时应该红灯亮5秒，在此等5秒print('\033[32m 绿灯亮! \033[0m')# 红的亮够5秒后，该绿灯亮了e.set()# 将is_set设置为Truedef Car(i,e):e.wait()# 车等在红绿灯，此时要看是红灯还是绿灯，如果is_set为True就是绿灯，此时可以过车print('第%s辆车过去了'%i)if __name__ == '__main__':e = Event()triff_light = Process(target=tra,args=(e,))# 信号灯的进程
    triff_light.start()for i in range(50):# 描述50辆车的进程if i % 3 == 0:time.sleep(2)car = Process(target=Car,args=(i+1,e,))car.start()