import threading
import time
from random import randint
# 演唱会门票总数量
TOTAL_TICKETS = 100
# 剩余门票数量
remaining_tickets = TOTAL_TICKETS
# 抢票函数
def grab_ticket(user_id):
global remaining_tickets
print(f"用户{user_id}正在尝试获取门票...")
# 模拟网络请求时间
time.sleep(2)
# 随机决定是否成功获取门票
success = bool(randint(0, 1))
if not success:
print(f"用户{user_id}没有成功获取门票。")
elif remaining_tickets > 0:
# 成功获取门票,将剩余门票数量减少1
remaining_tickets -= 1
print(f"恭喜!用户{user_id}已经成功获取了门票。")
else:
# 剩余门票数量为0,获取门票失败
print(f"非常抱歉,演唱会门票已经售罄,用户{user_id}没有成功获取门票。")
# 创建多个线程模拟多个用户同时进行抢票行为
threads = []
for i in range(5): # 假设有5个用户
thread = threading.Thread(target=grab_ticket, args=(i+1,))
thread.start()
threads.append(thread)
# 等待所有线程完成
for thread in threads:
thread.join()
print("所有用户的抢票行为已经完成。")
这个代码示例定义了一个grab_ticket
函数,模拟了抢票过程。每个线程都会调用这个函数来进行抢票行为。
在grab_ticket
函数中,首先输出一条消息,表示正在尝试获取门票,并延迟2秒钟模拟网络请求时间。然后,随机决定是否成功获取门票。如果没有成功,则输出相应的消息;否则,如果还有剩余门票,将剩余门票数量减少1,并通知用户获取门票成功;否则,将通知用户获取门票失败。
在main函数中,创建5个线程模拟5个用户同时进行抢票行为。每个线程都会调用grab_ticket
函数来进行抢票行为。最后,等待所有线程完成后输出所有用户的抢票行为已经完成。
当然,在实际应用中,可能还需要考虑并发、数据存储、异常处理等更多细节。上述示例只是一个简单的演示,仅供参考。
文章出处登录后可见!
已经登录?立即刷新