企业人力资源管理助手秒杀

import redis
import time

r = redis.Redis(host='localhost', port=6379, db=0)

def seckill_product(product_id, user_id):
    stock_key = f"stock:{product_id}"
    with r.pipeline() as pipe:
        while True:
            try:
                # 监视库存变化
                pipe.watch(stock_key)
                stock = int(pipe.get(stock_key) or 0)
                if stock <= 0:
                    return "Out of stock"
                
                # 开启事务
                pipe.multi()
                pipe.decr(stock_key)  # 减少库存
                pipe.execute()
                
                # 记录秒杀成功信息（此处可插入数据库操作）
                print(f"User {user_id} successfully秒杀Product {product_id}")
                return "Success"
            except redis.WatchError:
                continue  # 若监视的键被改动，则重试
            finally:
                pipe.reset()

# 模拟秒杀请求
for i in range(100):
    seckill_product("123", i)
    time.sleep(0.1)  # 模拟请求间隔