消息推送系统

import threading

from queue import Queue

class MessageCenter:

def __init__(self):

self.queue = Queue()

def add_message(self, message):

self.queue.put(message)

def process_messages(self):

while True:

message = self.queue.get()

print(f"Processing: {message}")

self.queue.task_done()

def main():

center = MessageCenter()

for i in range(5):

center.add_message(f"Request {i}")

thread = threading.Thread(target=center.process_messages)

thread.start()

center.queue.join()

print("All messages processed.")

if __name__ == "__main__":

main()