时间:2022-08-08 08:21:11 | 栏目:Python代码 | 点击:次
本文实例为大家分享了Python多线程模拟火车站售票的具体代码,供大家参考,具体内容如下
Python的标准库提供了两个模块:thread和threading,thread是低级模块,threading是高级模块,对thread进行了封装。
我们使用threading这个高级模块, 模拟火车站卖票,如果不加锁,卖出同一张票:
import threading from time import sleep, ctime N = 100 # 100张票 def Sell(name): global N while True: if N>0: sleep(0.1) #加入此句,可以让线程卖出第0张票或同一张票 print("{}卖出第{}张票!\n".format(name,N)) N=N-1 def main(): threads = {} for i in ( "A" ,"B" ): # 实例化每个 Thread 对象,把函数和参数传递进去,返回 Thread 实例 t = threading.Thread(target=Sell, args=( i ,)) threads[i]=t # 分配线程 for i in ("A" ,"B"): threads[i].start() # 开始执行多线程 for i in ("A" ,"B"): threads[i].join() # 等待线程结束或超时,然后再往下执行 print("程序结束!") if __name__ == '__main__': main()
运行效果:
我们使用锁来避免卖出同一张票,当多个线程同时执行lock.acquire()时,只有一个线程能成功地获取锁,然后继续执行代码,其他线程就等待直到获得锁为止。用try...finally来确保锁一定会被释放。
import threading from time import sleep, ctime N = 100 # 100张票 lock = threading.Lock() def Sell(name): global N while True: lock.acquire() try: if N>0: sleep(0.1) #加入此句,可以让线程卖出第0张票或同一张票 print("{}卖出第{}张票!\n".format(name,N)) N=N-1 finally: # 改完了一定要释放锁: lock.release() def main(): threads = {} for i in ( "A" ,"B" ): # 实例化每个 Thread 对象,把函数和参数传递进去,返回 Thread 实例 t = threading.Thread(target=Sell, args=( i ,)) threads[i]=t # 分配线程 for i in ("A" ,"B"): threads[i].start() # 开始执行多线程 for i in ("A" ,"B"): threads[i].join() # 等待线程结束或超时,然后再往下执行 print("程序结束!") if __name__ == '__main__': main()
运行效果: