乐趣区

关于python:python多线程同步售票系统解决思路

jiezi

解决问题场景：如果残余 1000 张电影票须要售卖，同时有 10 家电影 App 来售卖这 1000 张电影票。次要的逻辑实现过程是什么，要求应用 python 技术栈进行解题？

【浏览全文】

1、剖析过程

剖析：次要信息点是 10 家 App 平台同时售卖 1000 张电影票。此时，能够应用 10 个 python 线程来作为 10 家 App 平台，同时售卖必须保障电影票数量的同步，比方 A 平台卖出了一张票那总共残余的票数是 999，B 平台若要再卖出一张票则应该是 999-1=998 张票。

技术栈剖析：python 多线程提供了 threading 模块，并且 threading 模块提供了同步锁 Lock 来管制使得票数达到对立的成果。

2、筹备过程

将相干的规范库导入到代码块中，不必额定装置其余的非标准库。

import threading  # 多线程相干的操作

import os  # 利用退出操作

import time  # 线程中工夫阻塞的管制

初始化一些全局参数，供前面调用过程中应用。

tickets = 1000  # 初始化电影票的总数为 1000 张

lock_ = threading.Lock()  # 获取一个同步锁对象，用于在多线程逻辑中实现锁的管制

3、实现过程

编写一个函数 sell_tickets 作为售票的函数实现过程。

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)

至此，电影票售票的业务逻辑就写完了。上面再通过多线程实现多个电影票发售平台同时售票就 OK 了。

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()

【往期精彩】

发现几个好玩的游戏编程平台，与君共勉！

python 四个性能检测工具，包含函数的运行内存、工夫等等 …

如何将多张图片合成 mp4 视频格式，并退出背景音乐 …

python 如何实现网络测试，理解一下 speedtest-cli…

模型曾经写好了，怎么表白就看你的了！

退出移动版