这篇文章主要介绍“怎么用Python多线程实现模拟火车站售票”,在日常操作中,相信很多人在怎么用Python多线程实现模拟火车站售票问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”怎么用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()
运行效果:
到此,关于“怎么用Python多线程实现模拟火车站售票”的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注天达云网站,小编会继续努力为大家带来更多实用的文章!