当前位置 博文首页 > Python多线程实现模拟火车站售票

    Python多线程实现模拟火车站售票

    作者:程序员攻略 时间:2021-09-15 17:44

    本文实例为大家分享了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()

    运行效果:

    jsjbwy
    上一篇:Python函数基础
    下一篇:没有了