Python抢购数字藏品代码示例 - 线程安全实现

以下是一个简单的抢购数字藏品的Python代码示例，使用threading模块来保证线程安全。

import threading

class DigitalCollection:
    def __init__(self, name, total):
        self.name = name
        self.total = total
        self.left = total
        self.lock = threading.Lock()

    def buy(self, num):
        with self.lock:
            if self.left >= num:
                self.left -= num
                print(f'{num}个{self.name}抢购成功，还剩{self.left}个')
                return True
            else:
                print(f'{self.name}抢购失败，库存不足')
                return False

if __name__ == "__main__":
    collection = DigitalCollection('数字藏品', 10)

    def buy_collection(num):
        while True:
            success = collection.buy(num)
            if success:
                break

    threads = []
    for i in range(5):
        t = threading.Thread(target=buy_collection, args=(2,))
        threads.append(t)
        t.start()

    for t in threads:
        t.join()

代码中，定义了一个 DigitalCollection 类来表示数字藏品，包括名称、总数和剩余数量等属性，以及一个 buy 方法来模拟购买过程。在 buy 方法中，使用了 with self.lock 来保证购买时的线程安全。

在 main 函数中，创建了五个线程来同时进行抢购，每个线程尝试购买两个数字藏品，直到购买成功为止。使用 threads.append(t) 将每个线程对象加入到列表中，并使用 t.start() 启动线程。最后使用 t.join() 等待所有线程执行完毕。

此代码仅供参考，实际应用中还需要根据具体情况进行调整。