这边文章是实现同时有车辆出去，又有车辆进来的业务逻辑，和现实的差不多

真正要和现实中的一样，只需要更改休眠时间就可，通过调节修改时间，动态实现

之前的代码

python 多线程同步锁之实现停车场业务(1)

其他学习记录 ：

python 元类的学习记录

Python 的多线程(1) - 同步锁

Python 的多线程(2) - 队列

python 中的 set 放入带 list 的 tuple

以下是代码：

#!/usr/bin/env python
#                         ╭╮＿＿╭╭╭╭╭＿＿╭╮
#                          │　　　　　　　　　　　│　　 ╭—————╮
#                          │　　　　　　　　　　　│　　 │ｈｅｌｌｏ│
#                          │　●　╭———╮　●　    │　╭╮ │  world  │
#                          │ ≡　　│●　●│　　≡     │ ｏ╰╯ ╰—————╯
#                          │ 　　 ╰———╯　　 　 │　
#                           ╰——┬○————┬—○╯
#                          │＼＿__＿╭╭╭╭╭＿__＿／│ 　　
#                          │　　　　　　　　　　    │ 　╭—————————╮
#                          │　　　　No bug　　　　　 │　 ｜  No bug｜
#                          │　－　　　　　　　－　│　 ╰—————————╯
#                          │≡　　　　ｏ　　　　≡   │
#                          │　　　　　　　　　　　│　
#                          ╰———┬ｏ◤▽◥ｏ┬———╯
#                             ｜　　ｏ　 ｜
#                             ｜╭－－－╮ ｜
# -*- coding: utf-8 -*-
# @Time    : 2018/9/21 11:05
# @Author  : laof
# @Email   : 903900287@qq.com
# @File    : que.py
# @Software: PyCharm Community Edition"""这是一个停车场设计和实现"""#ps 关于小区停车场的设计实现级源码
#1. 小区有100个车位 ，小区有4个门口，分别是东南西北
#2. 一辆车只能占用一个车位
#3. 各个门口需要时时知道当前小区当前停车位的剩余数量
#4. 各个门口需要知道哪个位置被占用了,好分配等待的车辆进入import queue, threading
import random, time
from enum import Enum#定义停车位 队列，假设现在是晚上休息时间，停车场只进不出(没有要出去的车辆)
#这里是生产者的定义，只不过这个生产者是不变的
parkingLots = queue.Queue(100) #总共100个空车位#已被使用的停车位的队列
useParkingLots = queue.Queue(100)# 4个方向新增的车辆的队列(默认给个大点的值吧)
appendCarQueue = queue.Queue(100*100)#在4个门添加的新的等待车辆的队列
addCarQueue = queue.Queue(100*10)#通知消息的队列，这里假设我们的闸口屏幕能够显示的这么多
informs = queue.Queue(200)# 其实这里面放的就是已经被使用的车位的记录#定义东南西北4个门口
GeteDirectionEnum = Enum("GeteDirectionEnum",("东","西","南","北"))def put_all():for x in range(40):parkingLots.put("车位{0}号".format(x+1))#添加一些新车
def put_some_car():y = 0while True:y += 1time.sleep(6)addCarQueue.put("【{0}】新的车辆{1}".format(random.randint(4, 100)%4, y))#定义同步锁
gateLock = threading.Lock()#定义消费者（可以看作是4个门口的闸口，一闸一车）
class Gate(threading.Thread):def __init__(self, name, car_num):threading.Thread.__init__(self)self.__name = name  # 门口名字self.__carNum = car_num  #门口车子等待进入数量print("-{0}门-的闸口开始使用，门外等待数量{1}！".format(self.__name,self.__carNum))def run(self):self.open_gate()#　打开闸口放下一辆车辆进入def open_gate(self):"""开闸口"""sur = self.__carNumif not parkingLots.empty(): #如果停车场已经没有空车位了while not parkingLots.empty():try:gateLock.acquire() # 获得锁if not parkingLots.empty():if not appendCarQueue.empty():sur += 1   #如果发现有新车进来就在随机挺某一个门口吧informs.put("*************************>{0}门的排队的车辆新增了一辆，""新增后该门排队剩余数量为{1},最前面的一辆即将进入停车场,停车场的总空位数为{2}".format(self.__name,sur,parkingLots.qsize()))if not sur:informs.put("=========================>{0}门的排队车辆，已经全部进入停车场".format(self.__name))gateLock.release()# 释放锁breaksur -= 1place = parkingLots.get() # 获取停车位，并让一辆车子进去useParkingLots.put(place) # 放入已经被使用停车位列表time.sleep(1)   # 这里等待x秒，模拟车辆缴费刷卡进入停车场这个过程informs.put("【{0}】已经被{2}门使用,剩余停车位数量【{1}】个,---{2}门剩余排队车辆【{3}】辆".format(place,parkingLots.qsize(),self.__name,sur))#放入通知队列if parkingLots.qsize()==0:informs.put("【{0}】门 发现 停车位已经用完了，等待6秒，看还有没有车子出去".format(self.__name))time.sleep(5)gateLock.release()  # 释放锁except Exception as e:gateLock.release() #如果出现了异常一定要释放锁if parkingLots.empty(): # 通知所有门口，告知停车位已经用完了informs.put("1尊敬的业主您好，本小区中已经没有停车位了，请到周围转转看吧！{0}".format(self.__name))else:informs.put("2尊敬的业主您好，本小区中已经没有停车位了，请到周围转转看吧！")#定义车辆离开停车场的类
class LeaveThread(threading.Thread):"""车辆离开停车场的类"""def __init__(self):threading.Thread.__init__(self)def run(self):self.leave_from()@staticmethoddef leave_from():time.sleep(1)#这里就一个线程就不用加锁了while not useParkingLots.empty() and not parkingLots.full():time.sleep(4) #每8秒有一辆车离开nnn = useParkingLots.get()parkingLots.put(nnn)appendCarQueue.put(nnn)#这里为了方便假装，刚离开的车子转了一个圈又转回来了吧informs.put("【======={0}已空闲,当前剩余空车位数量位【{1}】========】".format(nnn,parkingLots.qsize()))# 开始定义主函数入口def show_log():"""显示停车位的信息"""n = 0while 1:n += 1#time.sleep(3)print(n, "-----", informs.get())if parkingLots.empty() and informs.empty() and useParkingLots.empty():breakif __name__ == "__main__":put_all()threads = []#启动一个线程，时时输出停车位的信息t = threading.Thread(target=show_log, name='carLogThread')t.start()#启动一个线程，离开某几辆车子leaveThread = LeaveThread()leaveThread.start()sum = 0# 循环 枚举，同时开始4个门口放行车辆for n, member in GeteDirectionEnum.__members__.items():if member.value == 4:x = parkingLots.qsize()-sumgate = Gate(n, x)threads.append(gate)breakx = random.randint(5,15)sum = sum + xgate = Gate(n, x)threads.append(gate)#同时启动for i,gate in enumerate(threads):gate.start()#等待所有的线程完毕for gate in threads:gate.join()t.join()print("已经夜深人静了，没有车辆进来的可以回家睡觉了")leaveThread.join()