统一消息系统

import threading

import queue

class MessageQueue:

def __init__(self):

self.queue = queue.Queue()

def publish(self, message):

self.queue.put(message)

def subscribe(self):

return self.queue.get()

def producer(queue):

for i in range(5):

queue.publish(f"Message {i}")

def consumer(queue):

while True:

message = queue.subscribe()

print(f"Received: {message}")

if message == "Message 4":

break

if __name__ == "__main__":

mq = MessageQueue()

t1 = threading.Thread(target=producer, args=(mq,))

t2 = threading.Thread(target=consumer, args=(mq,))

科研系统

t1.start()

t2.start()

t1.join()

t2.join()