本文实例为大家分享了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()
运行效果:
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持华域联盟。
您可能感兴趣的文章:
- Python进阶多线程爬取网页项目实战
- Python进阶篇之多线程爬取网页
- Python异步爬虫多线程与线程池示例详解
- Python并发编程队列与多线程最快发送http请求方式
- 分析详解python多线程与多进程区别
- python socket多线程实现客户端与服务器连接
- 手把手带你了解python多进程,多线程
- python多线程的线程如何安全实现
- python 多线程与多进程效率测试
本文由 华域联盟 原创撰写:华域联盟 » Python多线程实现模拟火车站售票
转载请保留出处和原文链接:https://www.cnhackhy.com/33580.htm