铁雪资源网 Design By www.gsvan.com
本文实例讲述了Python多线程经典问题之乘客做公交车算法。分享给大家供大家参考,具体如下:
问题描述:
乘客乘坐公交车问题,司机,乘客,售票员协同工作,通过多线程模拟三者的工作。
司机:开车,停车
售票员:打开车门,关闭车门
乘客:上车,下车
用Python的Event做线程同步通信,代码如下:
# *-* coding:gb2312 *-* import threading import time stationName=("车站0","车站1","车站2","车站3","车站4","车站5","车站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上车" %(self.no,stationName[currentStationIndex]) bAlreadyGetOnStation =True elif self.getoffStation == currentStationIndex: print "乘客%d在%s下车" %(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 "司机: 公交车开始行驶....." time.sleep(5) currentStationIndex += 1 print "司机: 到站 ",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 "售票员打开车门:%s到了" %(stationName[currentStationIndex]) eventOpenedDoor.set() time.sleep(5) print "售票员关闭车门" 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()
输出结果如下:
更多关于Python相关内容感兴趣的读者可查看本站专题:《Python进程与线程操作技巧总结》、《Python Socket编程技巧总结》、《Python图片操作技巧总结》、《Python数据结构与算法教程》、《Python函数使用技巧总结》、《Python字符串操作技巧汇总》、《Python入门与进阶经典教程》及《Python文件与目录操作技巧汇总》
希望本文所述对大家Python程序设计有所帮助。
铁雪资源网 Design By www.gsvan.com
广告合作:本站广告合作请联系QQ:858582 申请时备注:广告合作(否则不回)
免责声明:本站文章均来自网站采集或用户投稿,网站不提供任何软件下载或自行开发的软件! 如有用户或公司发现本站内容信息存在侵权行为,请邮件告知! 858582#qq.com
免责声明:本站文章均来自网站采集或用户投稿,网站不提供任何软件下载或自行开发的软件! 如有用户或公司发现本站内容信息存在侵权行为,请邮件告知! 858582#qq.com
铁雪资源网 Design By www.gsvan.com
暂无Python多线程经典问题之乘客做公交车算法实例的评论...
RTX 5090要首发 性能要翻倍!三星展示GDDR7显存
三星在GTC上展示了专为下一代游戏GPU设计的GDDR7内存。
首次推出的GDDR7内存模块密度为16GB,每个模块容量为2GB。其速度预设为32 Gbps(PAM3),但也可以降至28 Gbps,以提高产量和初始阶段的整体性能和成本效益。
据三星表示,GDDR7内存的能效将提高20%,同时工作电压仅为1.1V,低于标准的1.2V。通过采用更新的封装材料和优化的电路设计,使得在高速运行时的发热量降低,GDDR7的热阻比GDDR6降低了70%。