消息管理中心与方案的实现对话

import threading

import queue

class MessageCenter:

def __init__(self):

self.queue = queue.Queue()

self.running = True

def start(self):

while self.running:

message = self.queue.get()

print(f"收到消息: {message}")

self.queue.task_done()

def add_message(self, message):

self.queue.put(message)

if __name__ == "__main__":

center = MessageCenter()

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

thread.start()

center.add_message("用户登录成功")

center.add_message("数据更新完成")

thread.join()