Python多线程经典问题之乘客做公交车算法实例

# *-* coding:gb2312 *-*

importthreading

importtime

stationName=("车站0","车站1","车站2","车站3","车站4","车站5","车站6")

currentStationIndex=-1

eventBusStop=threading.Event()

eventClosedDoor=threading.Event()

eventOpenedDoor=threading.Event()

stationCount=len(stationName)

classPassenger(threading.Thread):

  def__init__(self,no,getonStation,getoffStation):

    self.no=no

    self.getonStation=getonStation

    self.getoffStation=getoffStation

    threading.Thread.__init__(self)

  defrun(self):

    bExit=False

    globalcurrentStationIndex

    globalstationCount

    bAlreadyGetOnStation=False

    whilenotbExit:

      eventOpenedDoor.wait()

      ifself.getonStation==currentStationIndexandbAlreadyGetOnStation==False:

        print"乘客%d在%s上车"%(self.no,stationName[currentStationIndex])

        bAlreadyGetOnStation=True

      elifself.getoffStation==currentStationIndex:

        print"乘客%d在%s下车"%(self.no,stationName[currentStationIndex])

        bExit=True

      time.sleep(1)

classDriver(threading.Thread):

  defrun(self):

    bExit=False

    globalcurrentStationIndex

    globalstationCount

    whilenotbExit:

      print"司机: 公交车开始行驶....."

      time.sleep(5)

      currentStationIndex+=1

      print"司机: 到站 ",stationName[currentStationIndex]

      eventBusStop.set()

      eventClosedDoor.wait()

      eventClosedDoor.clear()

      ifcurrentStationIndex==stationCount-1:

        bExit=True

classConductor(threading.Thread):

  defrun(self):

    bExit=False

    globalcurrentStationIndex

    globalstationCount

    whilenotbExit:

      eventBusStop.wait()

      eventBusStop.clear()

      print"售票员打开车门：%s到了"%(stationName[currentStationIndex])

      eventOpenedDoor.set()

      time.sleep(5)

      print"售票员关闭车门"

      eventOpenedDoor.clear()

      eventClosedDoor.set()

      ifcurrentStationIndex==stationCount-1:

        bExit=True

deftest():

  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)

  foriinrange(leng):

    passPool[i].start()

if__name__=='__main__':

  test()