消息推送系统

import queue

import threading

import time

def batch_sender(queue):

while True:

messages = []

for _ in range(10):

message = queue.get()

if message is None:

break

messages.append(message)

if messages:

print("发送批量消息:", messages)

time.sleep(1)

def producer(queue):

for i in range(50):

queue.put(f"消息 {i}")

queue.put(None) # 结束信号

q = queue.Queue()

t = threading.Thread(target=batch_sender, args=(q,))

t.start()

producer(q)

t.join()