Python多線程經(jīng)典問(wèn)題之乘客做公交車(chē)算法實(shí)例

更新時(shí)間：2017年03月22日 11:49:35 作者：聰明的狐貍

這篇文章主要介紹了Python多線程經(jīng)典問(wèn)題之乘客做公交車(chē)算法,簡(jiǎn)單描述了乘客坐公交車(chē)問(wèn)題并結(jié)合實(shí)例形式分析了Python多線程實(shí)現(xiàn)乘客坐公交車(chē)算法的相關(guān)技巧,需要的朋友可以參考下

本文實(shí)例講述了Python多線程經(jīng)典問(wèn)題之乘客做公交車(chē)算法。分享給大家供大家參考，具體如下：

問(wèn)題描述：

乘客乘坐公交車(chē)問(wèn)題，司機(jī)，乘客，售票員協(xié)同工作,通過(guò)多線程模擬三者的工作。
司機(jī)：開(kāi)車(chē)，停車(chē)
售票員：打開(kāi)車(chē)門(mén)，關(guān)閉車(chē)門(mén)
乘客：上車(chē)，下車(chē)

用Python的Event做線程同步通信，代碼如下：

# *-* coding:gb2312 *-*
import threading
import time
stationName=("車(chē)站0","車(chē)站1","車(chē)站2","車(chē)站3","車(chē)站4","車(chē)站5","車(chē)站6")
currentStationIndex = -1
eventBusStop = threading.Event()
eventClosedDoor = threading.Event()
eventOpenedDoor = threading.Event()
stationCount = len(stationName)
class Passenger(threading.Thread):
  def __init__(self,no,getonStation,getoffStation):
    self.no =no
    self.getonStation=getonStation
    self.getoffStation=getoffStation
    threading.Thread.__init__(self)
  def run(self):
    bExit= False
    global currentStationIndex
    global stationCount
    bAlreadyGetOnStation = False
    while not bExit:
      eventOpenedDoor.wait()
      if self.getonStation == currentStationIndex and bAlreadyGetOnStation == False:
        print "乘客%d在%s上車(chē)" %(self.no,stationName[currentStationIndex])
        bAlreadyGetOnStation =True
      elif self.getoffStation == currentStationIndex:
        print "乘客%d在%s下車(chē)" %(self.no,stationName[currentStationIndex])
        bExit = True
      time.sleep(1)
class Driver(threading.Thread):
  def run(self):
    bExit= False
    global currentStationIndex
    global stationCount
    while not bExit:
      print "司機(jī): 公交車(chē)開(kāi)始行駛....."
      time.sleep(5)
      currentStationIndex += 1
      print "司機(jī): 到站 ",stationName[currentStationIndex]
      eventBusStop.set()
      eventClosedDoor.wait()
      eventClosedDoor.clear()
      if currentStationIndex == stationCount-1:
        bExit= True
class Conductor(threading.Thread):
  def run(self):
    bExit= False
    global currentStationIndex
    global stationCount
    while not bExit:
      eventBusStop.wait()
      eventBusStop.clear()
      print "售票員打開(kāi)車(chē)門(mén)：%s到了" %(stationName[currentStationIndex])
      eventOpenedDoor.set()
      time.sleep(5)
      print "售票員關(guān)閉車(chē)門(mén)"
      eventOpenedDoor.clear()
      eventClosedDoor.set()
      if currentStationIndex == stationCount-1:
        bExit = True
def test():
  passPool=[]
  passPool.append(Passenger(0,0,3))
  passPool.append(Passenger(1,1,3))
  passPool.append(Passenger(2,2,4))
  passPool.append(Passenger(3,0,5))
  passPool.append(Passenger(4,1,3))
  passPool.append(Passenger(5,2,4))
  passPool.append(Passenger(6,4,5))
  passPool.append(Passenger(7,0,2))
  passPool.append(Passenger(8,1,3))
  passPool.append(Conductor())
  passPool.append(Driver())
  leng = len(passPool)
  for i in range(leng):
    passPool[i].start()
if __name__=='__main__':
  test()

輸出結(jié)果如下：