python教程分享python多线程同步售票系统

import threading  # 多线程相关的操作  import os  # 应用退出操作  import time  # 线程中时间阻塞的控制

tickets = 1000  # 初始化电影票的总数为1000张  lock_ = threading.lock()  # 获取一个同步锁对象，用于在多线程逻辑中实现锁的控制

def sell_tickets(app_name='承担电影票售票任务app平台'):      global tickets  # 将这些电影票作为全局变量      global lock_  # 将获取到的锁对象作为全局变量      # 使用一个死循环来模拟当前的售票平台一直在售票      while true:          lock_.acquire()  # 每个售票平台进入售票后先加锁处理          if tickets > 0:  # 开始售票之前先判断电影票的数量是否已经售完              tickets = tickets - 1              print('当前售票平台：{}，卖出一张电影票，剩余电影票：{}张！'.format(app_name, tickets))              time.sleep(0.1)          else:              print('电影票已经全部卖完了！')              os._exit(0)          lock_.release()  # 处理完成售票业务后将锁释放          time.sleep(0.2)  

app_thread_1 = threading.thread(target=sell_tickets, args=('售票app平台01',))  app_thread_1.start()  app_thread_2 = threading.thread(target=sell_tickets, args=('售票app平台02',))  app_thread_2.start()  app_thread_3 = threading.thread(target=sell_tickets, args=('售票app平台03',))  app_thread_3.start()  app_thread_4 = threading.thread(target=sell_tickets, args=('售票app平台04',))  app_thread_4.start()  app_thread_5 = threading.thread(target=sell_tickets, args=('售票app平台05',))  app_thread_5.start()  app_thread_6 = threading.thread(target=sell_tickets, args=('售票app平台06',))  app_thread_6.start()  app_thread_7 = threading.thread(target=sell_tickets, args=('售票app平台07',))  app_thread_7.start()  app_thread_8 = threading.thread(target=sell_tickets, args=('售票app平台08',))  app_thread_8.start()  app_thread_9 = threading.thread(target=sell_tickets, args=('售票app平台09',))  app_thread_9.start()  app_thread_10 = threading.thread(target=sell_tickets, args=('售票app平台10',))  app_thread_10.start()